8.启动一个线程 / 中断一个线程 / 等待一个线程

小雨的分享社区

发布于 2022-10-26 15:26:30

2170

发布于 2022-10-26 15:26:30

文章被收录于专栏：小雨的CSDN

启动一个线程

调用start()方法,才能正式启动一个线程

中断一个线程

中断就是让一个线程结束，结束可能有两种情况：

1.已经把任务执行完了

以下代码为例：

public class ThreadDemo7 {
    private static boolean isQuit = false;

    public static void main(String[] args) throws InterruptedException {
        Thread t = new Thread(){
            @Override
            public void run() {
                while (!isQuit){
                    System.out.println("正在转载");
                    try {
                        Thread.sleep(500);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                System.out.println("转载被终止");
            }
        };
        t.start();

        Thread.sleep(5000);
        System.out.println("需要赶快终止交易！！");
        isQuit = true;
    }
}

此时的结束方式是比较温和的，如果此时执行到sleep时，已经sleep了100ms了此时isQuit被设置成了true，不会立刻结束，而是把剩下的400ms执行完了在结束。

2.任务执行了一般，被强制结束了，可以调用线程的interrupt方法来实现

t.interrupt(); 可以给该线程触发一个异常

public class ThreadDemo8 {
    public static void main(String[] args) throws InterruptedException {
        Thread t = new Thread(){
            @Override
            public void run() {
                //此处直接使用线程内部的标志位
                while (!Thread.currentThread().isInterrupted()){
                    System.out.println("正在转载");
                    try {
                        Thread.sleep(500);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                        break;
                    }
                }
                System.out.println("终止转载");
            }
        };
        t.start();

        Thread.sleep(5000);
        System.out.println("赶快终止转载！！！！");
        t.interrupt();
    }
}

Thread.interrupted() 判断当前线程的中断标志被设置，清除中断标志，返回结果会改变。
Thread.currentThread().isInterrupted() 判断指定线程的中断标志被设置，不清除中断标志，其中Thread.currentThread().相当于this

等待一个线程

线程之间是并发执行的，如果现在创建一个新线程，，那么这时先打印新线程还是主线程是无法预知的。，这是抢占式执行的重要特点

虽然没法控制哪个线程先跑，但是可以控制让哪个线程先结束，哪个线程后结束

join方法执行时就会造成线程阻塞，一直阻塞到对应线程执行结束之后，才会继续执行，其存在的意义就是为了控制线程结束的先后顺序

public class ThreadDemo11 {
    public static void main(String[] args) throws InterruptedException {
        Thread t1 = new Thread(){
            @Override
            public void run() {
                for (int i = 0; i < 10; i++){
                    System.out.println("线程一");
                }
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        };
        Thread t2 = new Thread(){
            @Override
            public void run() {
                for (int i = 0; i < 10; i++){
                    System.out.println("线程二");
                }
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        };
        
        t1.start();
        t1.join();//当执行这里的时候，线程就阻塞了，一直到t1结束，才会往下执行
        t2.start();
        t2.join();
    }
}