标签:strong str pre false als 循环 iss 使用 同步
在多线程开发中停止线程是非常重要的技术点。
停止线程在Java语言中并不像break语句那样干脆。须要一些技巧性的处理。
採用异常法来停止一个线程。首先我们须要了解一下两个方法的使用方法:
public class MyThread extends Thread{ @Override public void run() { for (int i = 1; i <= 10000; i++) { System.out.println("i="+i); } } public static void main(String[] args)throws Exception { MyThread thread=new MyThread(); thread.start(); thread.sleep(10); thread.interrupt(); } }
调用interrupt()方法不过在当前线程打了一个停止的标记,并非真的停止。那么假设停止线程了?我们接着往以下看。
public class MyThread extends Thread{ @Override public void run() { for (int i = 1; i <= 10000; i++) { System.out.println("i="+i); } } public static void main(String[] args)throws Exception { try{ MyThread thread=new MyThread(); thread.start(); thread.sleep(100); thread.interrupt(); System.out.println("线程停止了吗1?--->"+thread.interrupted()); System.out.println("线程停止了吗2?--->"+thread.interrupted()); }catch(Exception e){ e.printStackTrace(); } System.out.println("end"); } }
public class MyThread{ public static void main(String[] args){ Thread.currentThread().interrupt(); System.out.println("线程停止了吗1?---->"+Thread.interrupted()); System.out.println("线程停止了吗2?---->"+Thread.interrupted()); System.out.println("end"); } }
可是为什么第2个值是false。原来。连续两次调用该方法第一次会清除中断状态后。第二次调用所以返回flase。
public class MyThread extends Thread{ @Override public void run() { for (int i = 1; i <= 10000; i++) { System.out.println("i="+i); } } public static void main(String[] args){ try{ MyThread thread=new MyThread(); thread.start(); thread.sleep(10); thread.interrupt(); System.out.println("线程停止了吗1?--->"+thread.isInterrupted()); System.out.println("线程停止了吗2?--->"+thread.isInterrupted()); }catch(Exception e){ e.printStackTrace(); } System.out.println("end"); } }
public class MyThread extends Thread{ @Override public void run() { for (int i = 1; i <= 10000; i++) { if(this.interrupted()){ System.out.println("线程是停止状态了,我要退出了."); break; } System.out.println("i="+i); } System.out.println("假设此处还是循环,那么我就会继续运行.线程并没有停止"); } public static void main(String[] args){ try{ MyThread thread=new MyThread(); thread.start(); thread.sleep(10); thread.interrupt(); System.out.println("end"); }catch(Exception e){ e.printStackTrace(); } } }
public class MyThread extends Thread{ @Override public void run() { try{ for (int i = 1; i <= 10000; i++) { if(this.interrupted()){ System.out.println("线程是停止状态了,我要退出了."); throw new InterruptedException(); } System.out.println("i="+i); } System.out.println("我被运行了吗?"); }catch(InterruptedException e){ System.out.println("---这次线程停了---"); e.printStackTrace(); } } public static void main(String[] args){ try{ MyThread thread=new MyThread(); thread.start(); thread.sleep(10); thread.interrupt(); System.out.println("end"); }catch(Exception e){ e.printStackTrace(); } } }
public class MyThread extends Thread{ @Override public void run() { try{ System.out.println("run start"); Thread.sleep(1000000); System.out.println("run end"); }catch(InterruptedException e){ System.out.println("sleep被停止,状态:--->"+this.isInterrupted()); e.printStackTrace(); } } public static void main(String[] args){ try{ MyThread thread=new MyThread(); thread.start(); thread.interrupt(); thread.sleep(1000); }catch(Exception e){ System.out.println("main catch"); e.printStackTrace(); } } }
public class MyThread extends Thread{ @Override public void run() { try{ for (int i = 1; i <= 10000; i++) { System.out.println("i="+i); } System.out.println("run start"); Thread.sleep(1000000); System.out.println("run end"); }catch(InterruptedException e){ System.out.println("线程被停止了。在sleep,状态:--->"+this.isInterrupted()); e.printStackTrace(); } } public static void main(String[] args){ try{ MyThread thread=new MyThread(); thread.start(); thread.interrupt(); }catch(Exception e){ System.out.println("main catch"); e.printStackTrace(); } } }
public class MyThread extends Thread{ private int i=0; @Override public void run() { try{ while (true) { i++; System.out.println("i="+i); Thread.sleep(1000); } }catch(Exception e){ e.printStackTrace(); } } public static void main(String[] args){ try{ MyThread thread=new MyThread(); thread.start(); Thread.sleep(6000); thread.stop(); }catch(Exception e){ e.printStackTrace(); } } }
public class MyThread extends Thread{ private int i=0; @Override public void run() { try{ while (true) { i++; if(this.interrupted()){ System.out.println("线程停止了"); return; } System.out.println("i="+i); } }catch(Exception e){ e.printStackTrace(); } } public static void main(String[] args){ try{ MyThread thread=new MyThread(); thread.start(); Thread.sleep(2000); thread.interrupt(); }catch(Exception e){ e.printStackTrace(); } } }
标签:strong str pre false als 循环 iss 使用 同步
原文地址:http://www.cnblogs.com/gccbuaa/p/6902928.html