使用線程池實現賣票

1：先寫一個Runnable。

package ThreadPool;

/**
 * @ProjectName: smartdata
 * @Package: ThreadPool
 * @ClassName: TicketRunnable
 * @Author: heluwei
 * @Description:
 * @Date: 2020/3/23 18:55
 * @Version: 1.0
 */
public class TicketRunnable implements Runnable {

    // 為了保持票數的一致，票數要靜態
    static int tick = 20;
    // 創建一個靜態鑰匙
    static Object ob = "aa";//值是任意的
    // 重寫run方法，實現買票操作
    @Override
    public void run() {
        while (tick > 0) {
            synchronized (ob) {// 這個很重要，必須使用一個鎖，
                // 進去的人會把鑰匙拿在手上，出來后才把鑰匙拿讓出來
                if (tick > 0) {
                    System.out.println(Thread.currentThread().getName() + "賣出了第" + tick + "張票");
                    tick--;
                } else {
                    System.out.println("票賣完了");
                }
            }
            try {
                Thread.sleep(1000);//休息一秒
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

}

二：使用線程池進行操作

package ThreadPool;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * @ProjectName: smartdata
 * @Package: ThreadPool
 * @ClassName: ThreadPoolExecutorDemo
 * @Author: heluwei
 * @Description: ThreadPoolExecutor線程池
 * @Date: 2020/3/21 20:35
 * @Version: 1.0
 */
public class ThreadPoolExecutorDemo {
    private static final int CORE_POOL_SIZE = 5; //核心線程數為 5
    private static final int MAX_POOL_SIZE = 10; //最大線程數 10
    private static final int QUEUE_CAPACITY = 100; //
    private static final Long KEEP_ALIVE_TIME = 1L; //當線程數大於核心線程數時，多余的空閑線程存活的最長時間

    public static void main(String... args) {
        //使用阿里巴巴推薦的創建線程池的方式
        //通過ThreadPoolExecutor構造函數自定義參數創建
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                CORE_POOL_SIZE,
                MAX_POOL_SIZE,
                KEEP_ALIVE_TIME, //當線程數大於核心線程數時，多余的空閑線程存活的最長時間
                TimeUnit.SECONDS, //時間單位
                new ArrayBlockingQueue<>(QUEUE_CAPACITY), //任務隊列，用來儲存等待執行任務的隊列
                new ThreadPoolExecutor.CallerRunsPolicy()); //飽和策略，簡單點說就是后面排隊的線程就在那兒等着。
                //被拒絕的任務在主線程中運行，所以主線程就被阻塞了，別的任務只能在被拒絕的任務執行完之后才會繼續被提交到線程池執行

        for (int i = 0; i < 5; i++) {
            //創建WorkerThread對象（WorkerThread類實現了Runnable 接口） 每一個Runable都是一個任務
            //Runnable worker = new MyRunnable("" + i);
            TicketRunnable ticketRunnable = new TicketRunnable(); 40             //執行Runnable
            executor.execute(ticketRunnable);

        }
        //終止線程池
        // void shutdown() 啟動一次順序關閉，執行以前提交的任務，但不接受新任務。若已經關閉，則調用沒有其他作用。
        executor.shutdown();
        //boolean isTerminated()
        //若關閉后所有任務都已完成，則返回true。注意除非首先調用shutdown或shutdownNow，否則isTerminated永不為true。
        while (!executor.isTerminated()) {
            //System.out.println("線程池還沒有完全關閉！！！");
        }
        System.out.println("Finished all threads");
    }
}