CompletableFuture 异步编排 -谷粒商城

ゝ一纸荒年。 2023-09-27 13:07 131阅读 0赞

### CompletableFuture 异步编排 -谷粒商城 ###

##### ThreadPoolExecutor 七大参数 #####

*  int corePoolSize\[5\]
    
     *  核心线程数\[一直存在除非设置(allowCoreThreadTimeOut)\]；线程池，创建好以后就准备就绪的线程数量，就等待来接受异步任务去执行。
     *  5个 Thread thread = new Thread(); thread .start()
 *  int maximumPoolSize
    
     *  最大线程数量；控制资源并发
 *  long keepAliveTime
    
     *  存活时间；如果当前正在运行的线程数量大于core数量，释放空闲的线程（maximumPoolSize-corePoolSize），只要线程空闲大于指定的keepAliveTime时间
 *  TimeUnit unit
    
     *  时间单位
 *  BlockingQueue workQueue
    
     *  阻塞队列；如果任务有很多，就会将目前多的任务放在队列里面，只要有线程空闲，就会去队列里面取出新的任务继续执行
 *  ThreadFactory threadFactory
    
     *  线程的创建工厂；
 *  RejectedExecutionHandler handler
    
     *  如果队列满了，按照指定的拒绝策略拒绝执行任务

1.  工作顺序
    
    1.  线程池创建，准备好core数量的核心线程，准备接受任务
        
        1.  core满了，就将再进来的任务放入阻塞队列中，空闲的core就会自己去阻塞队列获取任务执行
        2.  阻塞队列满了，就直接开新线程，最大只能开到max指定的数量
        3.  max满了，就用RejectedExecutionHandler 拒绝任务
        4.  max都执行完成，有很多空闲，在指定时间keepAliveTime以后，释放max-core这些线程
2.  面试题：一个线程池 core 7，max 20，queue 50,100并发进来怎么分配
    
    1.  回答：7个会立即执行，50个会进入队列，再开13个进行执行，剩下的30个就使用拒绝策略。如果不想抛弃还要执行。CallerRunsPolicy;同步执行策略

ThreadPoolExecutor executor = new ThreadPoolExecutor(5，200,10，TimeUnit.SECONDS);

import java.util.concurrent.*;
    
    public class ThreadTest {
        
    
        //当前系统中池只有一两个，每个异步任务直接提交给线程池，让他自己去执行
        public static ExecutorService executorService = Executors.newFixedThreadPool(10);
    
        public static void main(String[] args) {
        
    
    //        executorService.submit(new Runnable01());
    
            /**
             * 得到10个线程的线程池
             * Executors.newFixedThreadPool(10);
             *
             */
    
            /**
             * 七大参数
             int corePoolSize,
             int maximumPoolSize,
             long keepAliveTime,
             TimeUnit unit,
             BlockingQueue<Runnable> workQueue,
             ThreadFactory threadFactory,
             RejectedExecutionHandler handler
             */
            ThreadPoolExecutor executor = new ThreadPoolExecutor(
                    5,
                    200,
                    10, 
                    TimeUnit.SECONDS,
                    new LinkedBlockingQueue<>(10000),
                    Executors.defaultThreadFactory(),
                    new ThreadPoolExecutor.AbortPolicy());
    
    
        }
    
        public static class Runnable01 implements Runnable{
        
    
            @Override
            public void run() {
        
                System.out.println("Runnable01线程执行");
            }
        }
    }