Java 线程池之FixedThreadPool（Java代码实战-003）

 

import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.ThreadPoolExecutor; /** * FixThreadPoolExecutorTest 定义一个可重用的固线程数的线程池 */
public class FixThreadPoolExecutorTest { public static void main(String[] args) { /* * 把处理请求任务的线程数设置为固定的10， corePoolSize = maxPoolSize = 10 * keepAliveTime设置为0L，表示空闲的线程会立刻终止 * workQueue则是使用LinkedBlockingQueue，但是没有设置范围，那么则是最大值（Integer.MAX_VALUE） * 这基本就相当于一个无界队列了。 使用该“无界队列”则会带来哪些影响呢？当线程池中的线程数量等于corePoolSize * 时，如果继续提交任务，该任务会被添加到阻塞队列workQueue中，当阻塞队列也满了之后，则线程池会新建线程执行任务直到maximumPoolSize。  * 由于FixedThreadPool使用的是“无界队列”LinkedBlockingQueue，那么maximumPoolSize参数无效， * 同时指定的拒绝策略AbortPolicy也将无效。而且该线程池也不会拒绝提交的任务，如果客户端提交任务的速度快于任务的执行， * 那么keepAliveTime也是一个无效参数。 */ ExecutorService pool = Executors.newFixedThreadPool(10); // 始终只有10个线程来处理请求任务，来不及处理的任务会放置于阻塞队列中
        for (int i = 0; i < 50; i++) { pool.submit(new Runnable() { @Override public void run() { System.out.println("hello world! Execute ThreadName=" + Thread.currentThread().getName()); } }); } } }