Java Threadpool

来自WHY42
imported>Soleverlee2016年3月18日 (五) 03:10的版本 →‎使用线程池

JDK提供了ExecutorService以提供线程池的应用,今天测试了一下线程池的使用,受益匪浅。

不使用线程池

void normalThread(){
    final CountDownLatch lock = new CountDownLatch(testCount);
    for(int i = 0; i < testCount; i++){
        final int item = i;
        Thread t = new Thread(new Runnable(){

            @Override
            public void run() {
                handle(item);
                lock.countDown();
            }

        });
        t.start();
    }
    try {
        lock.await();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}

使用线程池

void useThreadPool(){
    final CountDownLatch lock = new CountDownLatch(testCount);
    final ExecutorService pool = Executors.newCachedThreadPool();
    for(int i = 0; i < testCount; i++){
        final int item = i;
        pool.execute(new Runnable(){
            @Override
            public void run() {
                handle(item);
                lock.countDown();
            }

        });
    }
    try {
        lock.await();
        pool.shutdown();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}