如何正确的使用ThreadPoolExecutor线程池

如何正确的使用ThreadPoolExecutor线程池，相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。

import java.util.Random;
import java.util.concurrent.*;

public class PoolTest {

    private BlockingQueue<Runnable> workingQueue = new ArrayBlockingQueue<Runnable>(10);
    private RejectedExecutionHandler rejectedExecutionHandler = new ThreadPoolExecutor.CallerRunsPolicy();
    private  ExecutorService threadPool = new ThreadPoolExecutor(10, 10, 0L, TimeUnit.MILLISECONDS, workingQueue, rejectedExecutionHandler);
    private Random random = new Random();

    public void test() {
        int size = 10;
        final CountDownLatch latch = new CountDownLatch(size);
        for(int i = 0; i < size; i ++) {
            threadPool.execute(new Runnable() {
                int x = random.nextInt(10);
                @Override
                public void run() {
                    try {
                        plus(x,x);
                    } finally {
                        latch.countDown();
                    }

                }
            });
        }
        try {
            latch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            System.out.println("线程全部执行完成");
        }

        threadPool.shutdown();
    }

    public void plus(int x, int y) {
        System.out.println("sum = " + (x + y));
    }

    public static void main(String[] args) {
        PoolTest poolTest = new PoolTest();
        poolTest.test();
    }
}

看完上述内容，你们掌握如何正确的使用ThreadPoolExecutor线程池的方法了吗？如果还想学到更多技能或想了解更多相关内容，欢迎关注亿速云行业资讯频道，感谢各位的阅读！