Java之前有一个api方法可以直接关闭线程,stop(),由于这个方法是强制性地关闭线程,有的时候会发生错误,之后就取消了,现在可用的方法主要有两种:
1、 在线程中加入一个成员变量,当一个flag使用。在线程run()方法中轮流去检查这个变量,变量变化时就退出这个线程。代码示例如下:
public class StopThread extends Thread { private boolean _run = true; public void stopThread(boolean run) { this._run = !run; } @Override public void run() { while(_run) { // 数据处理 } } }
2、 第一个方法虽然可以处理好,不过,在有阻塞线程的语句的时候往往不能处理好,因为线程被阻塞了,它便不能核查成员变量,就不能停止。比如, 涉及到Socket的阻塞语句server.accept().要使用某种机制使得阻塞线程更早地退出被阻塞的状态,这个时候可以使用Thread.interrupt()方法。Interrupt()方法只能解决跑出InterruptedException异常的阻塞。而interrupt()并不是关闭阻塞线程,而且解除阻塞。上一个例子:
public class BlockTask extends Thread { @Override public void run() { try { sleep(10000); } catch (InterruptedException e) { } } public static void main(String[] args)throws Exception { 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(); } }
时间: 2024-11-05 12:30:50