線程系列一、線程的創(chuàng)建與停止

BlackHole1 發(fā)布于2019-08-19 10:55 / 2369人閱讀

摘要：接口接口允許我們?cè)诰€程執(zhí)行的時(shí)候有返回值，以及拋出異常線程的停止類中的個(gè)停止方法三者區(qū)別將線程標(biāo)記為中斷返回線程當(dāng)前的中斷狀態(tài)，不清除線程的中斷標(biāo)記返回線程當(dāng)前的中斷狀態(tài)，并清除線程的中斷標(biāo)記與本質(zhì)都是調(diào)用了的。

1、通過(guò)繼承Thread類

public static class MThread extends Thread{

    @Override
    public void run() {
        System.out.println(this.getName() + " start");
    }
}

public static void main(String[] args){
    new MThread().start();
}

2、通過(guò)實(shí)現(xiàn)Runnable接口實(shí)現(xiàn)

public static class MRunnable implements Runnable {

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() +" start");
    }
}

public static void main(String[] args){
    new Thread(new MRunnable()).start();
}

3、創(chuàng)建可拋異常且有返回值的線程任務(wù)

public static class MCallAble implements Callable {
    @Override
    public String call() throws Exception {
        return Thread.currentThread().getName() + " 測(cè)試";
    }
}

public static void main(String[] args) throws ExecutionException, InterruptedException {
    FutureTask task = new FutureTask<>(new MCallAble());
    Thread thread = new Thread(task);
    thread.start();
    System.out.println(task.get());
}

解釋：

1、FutureTask的繼承類圖

因?yàn)镕utureTask最終實(shí)現(xiàn)的是Runnable接口，因此FutureTask可以直接放在Thread中執(zhí)行。

2、Callable接口

Callable接口允許我們?cè)诰€程執(zhí)行的時(shí)候有返回值，以及拋出異常！

4、線程的停止

①Thread類中的3個(gè)停止方法：

public void interrupt()
public static boolean interrupted()
public boolean isInterrupted()

②三者區(qū)別：

public void interrupt()

將線程標(biāo)記為中斷

public boolean isInterrupted() {
    return isInterrupted(false);
}

返回線程當(dāng)前的中斷狀態(tài)，不清除線程的中斷標(biāo)記

public static boolean interrupted() {
    return currentThread().isInterrupted(true);
}

返回線程當(dāng)前的中斷狀態(tài)，并清除線程的中斷標(biāo)記

interrupted() 與 isInterrupted() 本質(zhì)都是調(diào)用了 native的 isInterrupted()。interrupted()清除了標(biāo)記， isInterrupted()不清楚標(biāo)記。

③中斷示例代碼

static class Mclass implements Runnable {
    @Override
    public void run() {
        while (!Thread.interrupted()) {
            System.out.println(Thread.currentThread().getName() + " start ");
        }
    }
}

public static void main(String[] args) {
    Thread thread1 = new Thread(new Mclass());
    Thread thread2 = new Thread(new Mclass());
    thread1.start();
    thread2.start();
    thread1.interrupt();
}