class Thread1 extends Thread{
    public void run（）{
        System.out.println("線程運行代碼");
    }
}

//創(chuàng)建實例
    Thread1 t = new Thread（）; 

clas Runnable1 implements Runnable{
    public void run(){
        System.out.println("線程運行代碼");
    }
}
//創(chuàng)建實例
    Thread t = new Thread（new Runnable（））；

Thread t1 = new Thread(){
    public void run(){
        System.out.println("使用匿名類創(chuàng)建Tread子類對象");
    }
}

Thread t2 = new Thread(new Runnable(){
    public void run(){
        System.out.println("使用匿名類創(chuàng)建Runnable子類對象");
    }
});

 //使用lambda 表達式創(chuàng)建Runnable 子類對象
Thread t3 = new Thread (() -> System.out.println("使用匿名類創(chuàng)建Thread 子類對象"));


Thread t4 = new Thread (() -> {
     System.out.println("使用匿名類創(chuàng)建Thread 子類對象");
 });

// 用匿名內部類創(chuàng)建Callable對象
Callable<String> callableTask = new Callable<String>() {
    public String call() throws Exception {
        return "Callable任務執(zhí)行完成，返回結果";
    }
};

// 包裝成FutureTask，再交給Thread
FutureTask<String> futureTask = new FutureTask<>(callableTask);
Thread t5 = new Thread(futureTask);

// 用匿名內部類創(chuàng)建ThreadFactory
ThreadFactory factory = new ThreadFactory() {
    private int count = 0;
    public Thread newThread(Runnable r) {
        // 自定義線程名，方便調試
        return new Thread(r, "自定義線程-" + (++count));
    }
};

// 創(chuàng)建固定大小線程池
ExecutorService pool = Executors.newFixedThreadPool(3, factory);

// 提交任務（用匿名內部類Runnable）
pool.submit(new Runnable() {
    public void run() {
        System.out.println("線程池中的任務執(zhí)行");
    }
});

// 關閉線程池
pool.shutdown();

//采用  a)方法

public class demo {
    private static class MyRunnable implements Runnable{
        //volatile相當于一個主線程和子線程公用的開關
        public volatile boolean isQuit=false;
        @Override
        public void run() {
            while(!isQuit){
        //如果沒有收到停止指令，循環(huán)一直滿足，開始做奶茶
                System.out.println(Thread.currentThread().getName()+":我正在忙著做奶茶");
                try{
        //做一杯奶茶需要1s，也就是1s打印一次
                    Thread.sleep(1000);//這里把光標放在sleep下用alt+enter快捷鍵可以直接生成try，catch
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        //不進入while循環(huán)也就是收到停止指令時
            System.out.println(Thread.currentThread().getName()+":我現(xiàn)在來幫忙點單");
        }
    }

    public static void main(String[] args) throws InterruptedException {
        MyRunnable target=new MyRunnable();
        Thread thread=new Thread(target,"店員A");
        System.out.println(Thread.currentThread().getName()+":A,快去做奶茶");
        //讓A開始工作
        thread.start();
        //我去做3秒的事，a接著做奶茶每秒打印一次
        Thread.sleep(3000);
        //sleep結束，我叫a停止做奶茶
        System.out.println(Thread.currentThread().getName()+":A先別做奶茶了，快過來幫忙點單");
        target.isQuit=true;
    }
}

//采用   b）方法

public class demo2 {
    private static class MyRunnable implements Runnable{
        @Override
        public void run() {
            //while(!Thread.isterrupted())
            while (!Thread.currentThread().isInterrupted()){
                System.out.println(Thread.currentThread().getName()+":我正忙著做奶茶");
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    //收到中斷信號，處理異常
                    e.printStackTrace();
                    System.out.println(Thread.currentThread().getName()+":收到通知，停下手中的活");
                    //需著重注意這里的break，跳出循環(huán)，結束當前任務
                    break;
                }
            }
            //循環(huán)結束，執(zhí)行中斷后的收尾工作
            System.out.println(Thread.currentThread().getName()+":我現(xiàn)在過來點單");
        }
    }

    public static void main(String[] args) throws InterruptedException {
        MyRunnable target=new MyRunnable();
        Thread thread=new Thread(target,"A");
        System.out.println(Thread.currentThread().getName()+":快去做奶茶");
        thread.start();
        Thread.sleep(5000);
        System.out.println(Thread.currentThread().getName()+":A先別做奶茶了過來點單");
        thread.interrupt();
    }
}

public class demo3 {
    public static void main(String[] args) throws InterruptedException {
        Runnable target=()->{
         for(int i=0;i<3;i++){
                try {
                    System.out.println(Thread.currentThread().getName()+ ":我還在工作！");
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            System.out.println(Thread.currentThread().getName() + ":我結束了！");
        };
        Thread thread1=new Thread(target,"A");
        Thread thread2=new Thread(target,"B");
        System.out.println("先讓A開始工作");
        thread1.start();
        thread1.join();
        System.out.println("A工作結束，B開始工作");
        thread2.start();
        thread2.join();
        System.out.println("B工作結束");
    }
}

public class demo4 {
    public static void main(String[] args) {
        for (Thread.State state:Thread.State.values()) {
            System.out.println(state);
        }
    }
}