package com.base.demo.design.play;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

/**
 * @Description: 線程池代碼
 * @BelongsProject: base-demo-design
 * @BelongsPackage: com.base.demo.design.play
 * @Author: ChenYongJia
 * @CreateTime: 2021-08-14 15:26
 * @Email: chen87647213@163.com
 * @Version: 1.0
 */
public class TestThreadPoolExecutor {

    public static void main(String[] args) {
        // 創(chuàng)建使用單個線程的線程池
        ExecutorService es1 = Executors.newSingleThreadExecutor();
        for (int i = 0; i < 10; i++) {
            es1.submit(new Runnable() {
                @Override
                public void run() {
                    System.out.println(Thread.currentThread().getName() + "正在執(zhí)行任務(wù)");
                }
            });
        }

        // 創(chuàng)建使用固定線程數(shù)的線程池
        ExecutorService es2 = Executors.newFixedThreadPool(3);
        for (int i = 0; i < 10; i++) {
            es2.submit(new Runnable() {
                @Override
                public void run() {
                    System.out.println(Thread.currentThread().getName() + "正在執(zhí)行任務(wù)");
                }
            });
        }

        // 創(chuàng)建一個會根據(jù)需要創(chuàng)建新線程的線程池
        ExecutorService es3 = Executors.newCachedThreadPool();
        for (int i = 0; i < 20; i++) {
            es3.submit(new Runnable() {
                @Override
                public void run() {
                    System.out.println(Thread.currentThread().getName() + "正在執(zhí)行任務(wù)");
                }
            });
        }

        // 創(chuàng)建擁有固定線程數(shù)量的定時線程任務(wù)的線程池
        ScheduledExecutorService es4 = Executors.newScheduledThreadPool(2);
        System.out.println("時間：" + System.currentTimeMillis());
        for (int i = 0; i < 5; i++) {
            es4.schedule(new Runnable() {
                @Override
                public void run() {
                    System.out.println("時間："+System.currentTimeMillis()+"--"+Thread.currentThread().getName() + "正在執(zhí)行任務(wù)");
                }
            },3, TimeUnit.SECONDS);
        }

        // 創(chuàng)建只有一個線程的定時線程任務(wù)的線程池
        ScheduledExecutorService es5 = Executors.newSingleThreadScheduledExecutor();
        System.out.println("時間：" + System.currentTimeMillis());
        for (int i = 0; i < 5; i++) {
            es5.schedule(new Runnable() {
                @Override
                public void run() {
                    System.out.println("時間："+System.currentTimeMillis()+"--"+Thread.currentThread().getName() + "正在執(zhí)行任務(wù)");
                }
            },3, TimeUnit.SECONDS);
        }
    }

}

public ThreadPoolExecutor(int corePoolSize,//線程池的核心線程數(shù)量
        int maximumPoolSize,//線程池的最大線程數(shù)
        long keepAliveTime,//當(dāng)線程數(shù)大于核心線程數(shù)時，多余的空閑線程存活的最長時間
        TimeUnit unit,//時間單位
        BlockingQueue<Runnable> workQueue,//任務(wù)隊列，用來儲存等待執(zhí)行任務(wù)的隊列
        ThreadFactory threadFactory,//線程工廠，用來創(chuàng)建線程，一般默認(rèn)即可
        RejectedExecutionHandler handler) //拒絕策略，當(dāng)提交的任務(wù)過多而不能及時處理時，我們可以定制策略來處理任務(wù)

TimeUnit.DAYS;               //天
TimeUnit.HOURS;             //小時
TimeUnit.MINUTES;           //分鐘
TimeUnit.SECONDS;           //秒
TimeUnit.MILLISECONDS;      //毫秒
TimeUnit.MICROSECONDS;      //微妙
TimeUnit.NANOSECONDS;       //納秒

package com.base.demo.design.play;

import java.util.List;

/**
 * @Description: CPU測試
 * @BelongsProject: base-demo-design
 * @BelongsPackage: com.base.demo.design.play
 * @Author: ChenYongJia
 * @CreateTime: 2021-08-14 16:13
 * @Email: chen87647213@163.com
 * @Version: 1.0
 */
public class CPUTypeTest implements Runnable {

    /**
     * 整體執(zhí)行時間，包括在隊列中等待的時間
     */
    List<Long> wholeTimeList;

    /**
     * 真正執(zhí)行時間
     */
    List<Long> runTimeList;

    private long initStartTime = 0;

    /**
     * 構(gòu)造函數(shù)
     *
     * @param runTimeList
     * @param wholeTimeList
     * @return
     * @date 2021/8/14 16:13
     * @author ChenYongJia
     * @version 1.0
     */
    public CPUTypeTest(List<Long> runTimeList, List<Long> wholeTimeList) {
        initStartTime = System.currentTimeMillis();
        this.runTimeList = runTimeList;
        this.wholeTimeList = wholeTimeList;
    }

    /**
     * 判斷素數(shù)
     *
     * @param number
     * @return boolean
     * @date 2021/8/14 16:13
     * @author ChenYongJia
     * @version 1.0
     */
    public boolean isPrime(final int number) {
        if (number <= 1)
            return false;

        for (int i = 2; i <= Math.sqrt(number); i++) {
            if (number % i == 0)
                return false;
        }
        return true;
    }


    /**
     * 計算素數(shù)
     *
     * @param lower
     * @param upper
     * @return int
     * @date 2021/8/14 16:14
     * @author ChenYongJia
     * @version 1.0
     */
    public int countPrimes(final int lower, final int upper) {
        int total = 0;
        for (int i = lower; i <= upper; i++) {
            if (isPrime(i))
                total++;
        }
        return total;
    }

    @Override
    public void run() {
        long start = System.currentTimeMillis();
        countPrimes(1, 1000000);
        long end = System.currentTimeMillis();


        long wholeTime = end - initStartTime;
        long runTime = end - start;
        wholeTimeList.add(wholeTime);
        runTimeList.add(runTime);
        System.out.println("單個線程花費時間：" + (end - start));
    }

}

package com.base.demo.design.play;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.util.Vector;

/**
 * @Description: IO測試
 * @BelongsProject: base-demo-design
 * @BelongsPackage: com.base.demo.design.play
 * @Author: ChenYongJia
 * @CreateTime: 2021-08-14 16:18
 * @Email: chen87647213@163.com
 * @Version: 1.0
 */
public class IOTypeTest implements Runnable {

    /**
     * 整體執(zhí)行時間，包括在隊列中等待的時間
     */
    Vector<Long> wholeTimeList;

    /**
     * 真正執(zhí)行時間
     */
    Vector<Long> runTimeList;

    private long initStartTime = 0;

    /**
     * 構(gòu)造函數(shù)
     *
     * @param runTimeList
     * @param wholeTimeList
     */
    public IOTypeTest(Vector<Long> runTimeList, Vector<Long> wholeTimeList) {
        initStartTime = System.currentTimeMillis();
        this.runTimeList = runTimeList;
        this.wholeTimeList = wholeTimeList;
    }

    /**
     * IO操作
     *
     * @return void
     * @date 2021/8/14 16:18
     * @author ChenYongJia
     * @version 1.0
     */
    public void readAndWrite() throws IOException {
        File sourceFile = new File("D:/test.txt");
        //創(chuàng)建輸入流
        BufferedReader input = new BufferedReader(new FileReader(sourceFile));
        //讀取源文件,寫入到新的文件
        String line = null;
        while ((line = input.readLine()) != null) {
            //System.out.println(line);
        }
        //關(guān)閉輸入輸出流
        input.close();
    }

    @Override
    public void run() {
        long start = System.currentTimeMillis();
        try {
            readAndWrite();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        long end = System.currentTimeMillis();


        long wholeTime = end - initStartTime;
        long runTime = end - start;
        wholeTimeList.add(wholeTime);
        runTimeList.add(runTime);
        System.out.println("單個線程花費時間：" + (end - start));
    }

}