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

 

原创文章,作者:奋斗,如若转载,请注明出处:https://blog.ytso.com/tech/pnotes/15930.html

(0)
上一篇 2021年7月19日 18:51
下一篇 2021年7月19日 18:51

相关推荐

发表回复

登录后才能评论