国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Java > 正文

Java線程關閉的3種方法

2019-11-26 15:56:50
字體:
來源:轉載
供稿:網友

Java線程關閉,總的來說有3種:

1.使用狀態位,這個簡單,就不多說了:

復制代碼 代碼如下:

public class Task extends Thread {

private volatile boolean flag= true;

public void stopTask() {

flag = false;

}

@Override

public void run() {

while(flag){

/* do your no-block task */

}

}

}


2.當線程等待某些事件發生而被阻塞,又會發生什么?當然,如果線程被阻塞,它便不能核查共享變量,也就不能停止。這在許多情況下會發生,例如調用 Object.wait()、Thread.sleep等,這里僅舉出一些。他們都可能永久的阻塞線程。即使發生超時,在超時期滿之前持續等待也是不可行和不適當的,所以,要使用某種機制使得線程更早地退出被阻塞的狀態。這個時候你可以使用
復制代碼 代碼如下:

Thread.interrupt();

public class BlockTask extends Thread {

@Override

public void run() {

try {

while (!Thread.interrupted()) {

/* do your block task*/

}

} catch (Exception e) {

e.printStackTrace();

}

}

}


但是上面的代碼或許有些不妥,或許用例子更能把問題說清楚。你怎么知道該代碼段會發生阻塞?interrupt()函數到底是什么意思呢?首先說明的是,interrupted()方法只能解決跑出InterruptedException異常的阻塞。而interrupt()并不是關閉阻塞線程,而是解除阻塞。那這里就舉出一個關閉線程阻塞的例子:
復制代碼 代碼如下:

public class BlockTask extends Thread {

@Override

public void run() {

try {

sleep(10000);

} catch (InterruptedException e) {

System.out.println("if yout use interrupt you will see me");

}


}

public static void main(String[] args)throws Exception {

// TODO Auto-generated method stub

BlockTask task = new BlockTask();

task.start();

Thread.sleep(1000);

task.interrupt();


}

}


3.上面說了,interrupt()只能解決InterruptedException的阻塞的線程,那么遇到一些其他的io阻塞怎么處理呢?這個時候java都會提供相應的關閉阻塞的辦法。例如,服務器可能需要等待一個請求(request),又或者,一個網絡應用程序可能要等待遠端主機的響應,這個時候可以使用套接字close()方法
復制代碼 代碼如下:

public class SocketTask extends Thread {

private volatile ServerSocket server;


public void stopTask(){

try {

if(server!=null){

server.close();

System.out.println("close task successed");

}

} catch (IOException e) {

System.out.println("close task failded");

}

}

@Override

public void run() {

try {

server = new ServerSocket(3333);

} catch (IOException e) {

e.printStackTrace();

}

}

public static void main(String[] args) throws InterruptedException {


SocketTask task = new SocketTask();

task.start();

Thread.sleep(1000);

task.stopTask();

}

}

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 鄄城县| 邹城市| 花莲市| 中山市| 仙游县| 宿州市| 台江县| 漠河县| 册亨县| 芒康县| 雅江县| 远安县| 罗城| 阜城县| 漯河市| 麻城市| 南岸区| 康保县| 宜春市| 岳阳县| 商水县| 桃园市| 海晏县| 资源县| 汉川市| 黑龙江省| 黔南| 灌南县| 神农架林区| 林周县| 高青县| 商水县| 定安县| 河北省| 梨树县| 清远市| 建阳市| 苍溪县| 通辽市| 苏尼特右旗| 桓仁|