如何正確的使用ThreadPoolExecutor線程池，相信很多沒(méi)有經(jīng)驗(yàn)的人對(duì)此束手無(wú)策，為此本文總結(jié)了問(wèn)題出現(xiàn)的原因和解決方法，通過(guò)這篇文章希望你能解決這個(gè)問(wèn)題。

創(chuàng)新互聯(lián)-專業(yè)網(wǎng)站定制、快速模板網(wǎng)站建設(shè)、高性價(jià)比秦皇島網(wǎng)站開(kāi)發(fā)、企業(yè)建站全套包干低至880元,成熟完善的模板庫(kù),直接使用。一站式秦皇島網(wǎng)站制作公司更省心,省錢,快速模板網(wǎng)站建設(shè)找我們，業(yè)務(wù)覆蓋秦皇島地區(qū)。費(fèi)用合理售后完善，十余年實(shí)體公司更值得信賴。

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

public class PoolTest {

    private BlockingQueue workingQueue = new ArrayBlockingQueue(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("線程全部執(zhí)行完成");
        }

        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();
    }
}

看完上述內(nèi)容，你們掌握如何正確的使用ThreadPoolExecutor線程池的方法了嗎？如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝各位的閱讀！