Java并发编程之线程生命周期、守护线程、优先级、关闭和join、sleep、yield、interrupt

 1 public class ThreadInterrupt {
 2 
 3     public static void main(String[] args) throws InterruptedException {
 4         Thread thread = new Thread() {
 5             public void run() {
 6                 while(true) {
 7                     try {
 8                         /*
 9                          * sleep为可中断方法, 因此会擦除interrupt标志;
10                          * 如果注释掉sleep方法, thread收到中断信号后,interrupt标志不会被移除
11                          */
12                         TimeUnit.MINUTES.sleep(2);
13                     } catch (InterruptedException e) {
14                         System.out.printf("I am be interrupted? %s\n", isInterrupted());
15                     }
16                 }
17             }
18         };
19         thread.setDaemon(true);
20         thread.start();
21         //确保thread线程启动完毕
22         TimeUnit.SECONDS.sleep(2);
23         System.out.printf("I am be interrupted? %s\n", thread.isInterrupted());
24         //在main线程中, 调用线程对象thread的interrupt()方法, 中断thread线程的sleep阻塞状态.
25         thread.interrupt();
26         //确保thread线程进入Runnable并被线程调度器调动
27         TimeUnit.SECONDS.sleep(2);
28         System.out.printf("I am be interrupted? %s\n", thread.isInterrupted());
29     }
30 }

 1 public class ThreadInterrupted {
 2 
 3     public static void main(String[] args) throws InterruptedException {
 4         
 5         Thread thread = new Thread(() -> {
 6             while (true) {
 7                 if(Thread.interrupted()) {
 8                     System.out.println("Yes my interrupt flag has been removed!");
 9                 }else {
10                     System.out.println("I am running");
11                 }
12             }
13         });
14         
15         thread.setDaemon(true);
16         thread.start();
17         
18         //Main sleep to make sure thread start
19         TimeUnit.MILLISECONDS.sleep(2);
20         thread.interrupt();
21         //以下显示false
22         System.out.println("Main thread is interrupted? " + Thread.interrupted());
23         
24         Thread.currentThread().interrupt();
25         //以下显示true
26         System.out.println("Main thread is interrupted? " + Thread.currentThread().isInterrupted());
27         
28         try {
29             TimeUnit.MINUTES.sleep(2);
30         } catch (Exception e) {
31             System.out.println("I am be interrupted!!!!!!");
32         }
33     }
34 }

 1 public class InterruptThreadExit {
 2 
 3     public static void main(String[] args) throws InterruptedException {
 4         
 5         Thread t = new Thread() {
 6             @Override
 7             public void run() {
 8                 System.out.println("I will start to work");
 9                 //此处通过IsInterrupt或interrupted方法来判断中断状态, 以便控制while循环实现控制线程关闭的目的
10                 while(!interrupted()) {
11                     //System.out.println(isInterrupted());
12                 }
13                 System.out.println(isInterrupted());
14                 System.out.println("I will exit");
15             }
16         };
17         t.start();
18         TimeUnit.SECONDS.sleep(3);
19         System.out.println("ready to send interrupt signal");
20         t.interrupt();
21     }
22 }

 1 /*
 2  * 通过volatile修饰符, 设置开关来控制线程关闭
 3  */
 4 public class FlagThreadExit {
 5     
 6     static class MyTask extends Thread{
 7         //使用volatile修饰一个boolean开关变量
 8         private volatile boolean closed = false;
 9         public void run() {
10             System.out.println("I will start to work");
11             //通过开变量和中断标识, 以便控制while循环实现控制线程关闭的目的
12             while(!closed && !interrupted()) {
13                 //working
14             }
15             System.out.println("I will exit");
16         }
17         //定义用于关闭的close方法, 设置开关变量和调用中断方法
18         public void close() {
19             closed = true;
20             interrupt();
21         }
22     }
23 
24     public static void main(String[] args) throws InterruptedException {
25         MyTask t = new MyTask();
26         t.start();
27         TimeUnit.SECONDS.sleep(2);
28         System.out.println("use close method");
29         t.close();
30     }
31 }