Java如何关闭线程

来源:爱站网时间:2019-11-22编辑:网友分享
在Java中线程属于一次性产品,当我们需要再次使用的时候只能重新新的线程对象,但是有时候run()方法是永远不会结束的,那么这个时候Java如何关闭线程呢?下面就一起去看看解决方法吧。

Java线程属于一次性产品,当我们需要再次使用的时候只能重新新的线程对象,但是有时候run()方法是永远不会结束的,那么这个时候Java如何关闭线程呢?下面就一起去看看解决方法吧。

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();

}

}

看完后你知道Java如何关闭线程了吗?如果你觉得本文对你有帮助的话就请收藏转发给有需要的朋友们吧,让更多的人能够享受到获取知识的快乐!

上一篇:JAVA读取属性文件的方法

下一篇:Java常见排序算法的实现代码

您可能感兴趣的文章

相关阅读

热门软件源码

最新软件源码下载