zoukankan      html  css  js  c++  java
  • 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());
                    }
                });
            }
        }
    }
  • 相关阅读:
    Cocos2dx 3.0 交流篇
    android获取ip和本机的物理地址
    半平面交总结and模板
    页面跳转的三种方式
    83. 从视图索引说Notes数据库(上)
    IE7IE8兼容性设置_服务器端设定
    [置顶] 王志成30岁前自传-我曾创造过的“第一”
    Android CTS 结果 testResult.xml 修改 fail 项 为 notExecuted 项 分析
    java android面试题分析总结
    android之写文件到sd卡
  • 原文地址:https://www.cnblogs.com/telwanggs/p/13979775.html
Copyright © 2011-2022 走看看