package com.scg.springcloudordercenter.controller;
 
// 1.繼承Thread類
public class ThreadDemo extends Thread{
 
    private int ticket=20;
 
    // 2.重寫run 方法
    public void run(){
        for(int i=0;i<20;i++){
 
            if(this.ticket>0){
                System.out.println("剩余票數(shù)=="+ticket--);
            }
        }
 
    }
}
 
class ThreadTest {
    public static void main(String[] args) {
        // 3.實(shí)例化線程對象
        ThreadDemo md = new ThreadDemo() ;
        // 4.調(diào)用start()開啟線程
        md.start();
    }
}
 
 

package com.scg.springcloudordercenter.controller;
 
 
// 1.實(shí)現(xiàn)Runnable類
public class RunnableDemo implements Runnable{
 
    private int ticket=20;
 
    // 2.重寫run 方法
    public void run(){
        for(int i=0;i<20;i++){
 
            if(this.ticket>0){
                System.out.println("剩余票數(shù)=="+ticket--);
            }
        }
 
    }
}
 
class RunnableTest {
    public static void main(String[] args) {
        // 3.實(shí)例化實(shí)現(xiàn)類
        RunnableDemo rd = new RunnableDemo() ;
        // 4.將實(shí)例化實(shí)現(xiàn)類轉(zhuǎn)化為線程對象
        Thread thread = new Thread(rd);
        // 5.開啟線程
        thread.start();
    }
}
 
 

/**
 * @author gf
 * @date 2023/2/22
 */
// 1、定義一個(gè)線程任務(wù)類實(shí)現(xiàn)Callable接口，聲明線程執(zhí)行的結(jié)果類型。
public class CallableTicket implements Callable<Object > {
 
    private int ticket=20;
 
    // 2、重寫線程任務(wù)類的call()方法，這個(gè)方法可以直接返回執(zhí)行的結(jié)果。
    @Override
    public Object  call() throws Exception {
        int sum = 0;
        for (int i = 1; i <= 100; i++) {
            if (i % 2 == 0) {
                sum += i;
            }
        }
        return sum;
    }
 
}

package com.scg.springcloudordercenter.controller;
 
import java.util.concurrent.FutureTask;
 
/**
 * @author gf
 * @date 2023/2/22
 */
public class CallableMain {
 
    public static void main(String[] args) {
 
        // 3、創(chuàng)建一個(gè)Callable的線程任務(wù)對象。
        CallableTicket callableTicket = new CallableTicket();
 
        // 4、把Callable的線程任務(wù)對象包裝成一個(gè)未來任務(wù)對象。
        FutureTask futureTask = new FutureTask(callableTicket);
 
        // 5、把未來任務(wù)對象包裝成線程對象。
        Thread thread = new Thread(futureTask);
 
        // 6、調(diào)用線程start()方法，啟動(dòng)線程。
        thread.start();
 
        // 7、獲取線程執(zhí)行結(jié)果。如果此時(shí)獲取結(jié)果的任務(wù)還未執(zhí)行完成，會(huì)讓出CPU，直至任務(wù)執(zhí)行完成才獲取結(jié)果。
        try {
            //6.獲取Callable中call方法的返回值
            //get()返回值即為FutureTask構(gòu)造器參數(shù)Callable實(shí)現(xiàn)類重寫的call()方法返回值。
            Object sum = futureTask.get();
            System.out.println("總和為："+sum);
        } catch (Exception e) {
            e.printStackTrace();
        }
 
 
    }
}

public class Demo01 {
    public static void main(String[] args) {
        //ExecutorService threadPool = Executors.newSingleThreadExecutor(); //創(chuàng)建單個(gè)線程
        //ScheduledExecutorService threadPool = Executors.newScheduledThreadPool(5);//創(chuàng)建一個(gè)固定大小的線程池
        //ExecutorService threadPool = Executors.newFixedThreadPool(5); //創(chuàng)建一個(gè)固定大小的線程池
        ExecutorService threadPool = Executors.newCachedThreadPool(); //創(chuàng)建大小可伸縮的線程池
 
        try {
            for (int i = 0; i < 30; i++) {
                //使用線程池來創(chuàng)建線程
                threadPool.execute(()->{
                    System.out.println(Thread.currentThread().getName()+"ok");
                });
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            threadPool.shutdown(); //線程池使用完畢后需要關(guān)閉
        }
 
    }
}

public class Demo02 {
    public static void main(String[] args) {
        //new ThreadPoolExecutor.AbortPolicy():達(dá)到最大承載量，不再處理，并且拋出異常
        //new ThreadPoolExecutor.CallerRunsPolicy():達(dá)到最大承載量，從哪來的去哪里
        //new ThreadPoolExecutor.DiscardPolicy():達(dá)到最大承載量，丟掉任務(wù)，但不拋出異常
        //new ThreadPoolExecutor.DiscardOldestPolicy():達(dá)到最大承載量，嘗試與最早執(zhí)行的線程去競爭，不拋出異常
 
        //最大線程池大小該如何定義
        //1.cpu密集型，邏輯處理器個(gè)數(shù)
        //2.io密集型 > 判斷程序十分耗IO的線程，最大線程池大小應(yīng)該比這個(gè)大
        int maxPools= Runtime.getRuntime().availableProcessors();
        System.out.println(maxPools);
 
        ThreadPoolExecutor threadPool = new ThreadPoolExecutor(
                2,
                maxPools,
                3,
                TimeUnit.SECONDS,
                new ArrayBlockingQueue<>(3),
                Executors.defaultThreadFactory(),
                new ThreadPoolExecutor.DiscardOldestPolicy()
        );
 
        try {
            for (int i = 0; i < 10; i++) {
                //使用線程池來創(chuàng)建線程
                //最大承載：maximumPoolSize+workQueue，超過執(zhí)行拒絕策略
                threadPool.execute(()->{
                    System.out.println(Thread.currentThread().getName()+" ok");
                });
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            threadPool.shutdown(); //線程池使用完畢后需要關(guān)閉
        }
 
    }
}