并发编程——java并发包之线程池

连接池定义

　　java中为了提高并发度，可以使用多线程共同执行。但是如果有大量线程短时间之内被创建和销毁，会占用大量的系统时间，影响系统效率。

　　为了解决上面的问题，java中引入了线程池，可以使创建好的线程在指定的时间内由系统统一管理，而不是在执行时创建，执行后就销毁，从而避免了频繁创建、销毁线程带来的系统开销。

常用的线程池

• newCachedThreadPool（线程池中线程数量不做限制，可以动态扩展，可以指定或不指定线程池中线程多少，每一个线程默认失效时间为60s，即线程空闲后60s会被回收）
• newFixedThreadPool（固定线程数量的线程池，如果超过此数量则阻塞在内部队列中）
• newSingleThreadExecutor（上例的特例，只有1个线程）

• newScheduleThreadPool（创建一个定长的线程池，而且支持定时的以及周期性的任务执行，支持定时及周期性任务执行）

应用举例

package threadPool;

public class ThreadSample extends Thread {
    private String param;
    
    public ThreadSample(String param) {
        this.param = param;
    }

    @Override
    public void run() {
        System.out.println(param);
    }
}

package threadPool;

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

import org.junit.Test;

public class ThreadPool {
    
    @Test
    public void testCacheThreadPool() throws InterruptedException {
        ExecutorService service = Executors.newCachedThreadPool();
        for (int i = 0; i < 10; i++) {
            Thread sample = new ThreadSample("Thread-" + i);
            service.execute(sample);
            sample.join();
        }
    }
    
    @Test
    public void testFixThreadPool() throws InterruptedException {
        ExecutorService service = Executors.newFixedThreadPool(10);
        for (int i = 0; i < 10; i++) {
            Thread sample = new ThreadSample("Thread-" + i);
            service.execute(sample);
            sample.join();
        }
    }
    
    @Test
    public void testSingleThreadPool() throws InterruptedException {
        ExecutorService service = Executors.newSingleThreadExecutor();
        for (int i = 0; i < 10; i++) {
            Thread sample = new ThreadSample("Thread-" + i);
            service.execute(sample);
            sample.join();
        }
    }
    
    @Test
    public void testScheduleThreadPool() throws InterruptedException {
        ScheduledExecutorService service = Executors.newScheduledThreadPool(5);
        Thread sample = new ThreadSample("Thread");
        service.scheduleWithFixedDelay(sample, 5, 3, TimeUnit.SECONDS);
        
        Thread.sleep(20*1000);
    }
}