join()方法和中断线程

系统管理员 2021-10-18 09:50 267阅读 0赞

### 中断线程： ###

###        自定义标记的方式      ###

package com.vince;
    
    /**
     * Thread.currentThread():获取当前线程
     * 中断线程：
     *      自定义标记的方式
     */
    public class ThreadDemo2 {
        public static void main(String[] args) {
            //实现runable接口:  没有开辟线程的能力，要将创建的对象交给指定线程来运行
            MyRunnable3 mr3 = new MyRunnable3();
            Thread t1 = new Thread(mr3);
            t1.start();
    
            for(int i = 0; i < 10; i++){
                System.out.println(Thread.currentThread().getName()+"--"+i);
                try {
                    Thread.sleep(300);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                if(i == 5){
                    mr3.flag = false;
                }
            }
        }
    }
    
    class  MyRunnable3 implements  Runnable{
        public boolean flag = true;
        public MyRunnable3(){
               flag = true;
        }
        @Override
        public void run() {
            int i = 0;
            while (flag){
                System.out.println(Thread.currentThread().getName()+"####"+(i++));
                try {
                    Thread.sleep(300);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzMTM0MjA4NDc3Ng_size_16_color_FFFFFF_t_70][]

### join方法：          加入线程，让调用的线程先执行，指定时间或执行完毕 ###

package com.vince;
    
    /**
     * Thread.currentThread():获取当前线程
     * join方法：
     *     加入线程，让调用的线程先执行，指定时间或执行完毕
     */
    public class ThreadDemo2 {
        public static void main(String[] args) {
            //实现runable接口:  没有开辟线程的能力，要将创建的对象交给指定线程来运行
            MyRunnable2 mr2 = new MyRunnable2();
            Thread t = new Thread(mr2);
            t.start();
    
            for(int i = 0; i < 10; i++){
                System.out.println(Thread.currentThread().getName()+"--"+i);
                try {
                    Thread.sleep(300);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                if(i == 5){
                    try {
                        t.join();//让t线程执行完毕
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                 }
            }
        }
    }
    
    class MyRunnable2 implements Runnable{
        @Override
        public void run() {
            for(int i = 0; i < 10; i++){
               System.out.println(Thread.currentThread().getName()+"--"+i);
                try {
                    Thread.sleep(300);
                } catch (InterruptedException e) {
                    e.printStackTrace();
             }
            }
        }
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzMTM0MjA4NDc3Ng_size_16_color_FFFFFF_t_70 1][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzMTM0MjA4NDc3Ng_size_16_color_FFFFFF_t_70]: /images/20211018/4f557fcf214a4d139fb21af7c4e30d3a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzMTM0MjA4NDc3Ng_size_16_color_FFFFFF_t_70 1]: /images/20211018/ffaab2e1ca6e4e238aba217e98994f2c.png