使用ThreadPoolExecutor进行多线程编程

2021-06-17 16:05

阅读：548

标签：proc override 大于 reads cut process tor this 接口

ThreadPoolExecutor有四个构造函数，分别是：

1，ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue workQueue)
2，ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime,TimeUnit unit,BlockingQueue workQueue,RejectedExecutionHandler handler)
3，ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime,TimeUnit unit,BlockingQueue workQueue,ThreadFactory threadFactory)
4，ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime,TimeUnit unit,BlockingQueue workQueue,ThreadFactory threadFactory,RejectedExecutionHandler handler)

其中的参数分别如下：

1 corePoolSize（线程池的基本大小）:当提交一个任务到线程池时，线程池会创建一个线程来执行任务，即使其他空闲的基本线程能够执行新任务也会创建线程，等到需要执行的任务数大于线程池基本大小时就不再创建。如果调用了prestartAllCoreThreads()方法，线程池会提前创建并启动所有基本线程。

2 maximumPoolSize（线程池最大数量）：线程池允许创建的最大线程数。如果队列满了，并且已创建的线程数小于最大线程数，则线程池会再创建新的线程执行任务。值得注意的是，如果使用了无界的任务队列这个参数就没用了。

3 keepAliveTime(线程活动时间):线程池的工作线程空闲后，保持存活的时间。所以如果任务很多，并且每个任务执行的时间比较短，可以调大时间，提高线程利用率。

4 TimeUnit(线程活动时间的单位)：可选的单位有天（Days）、小时（HOURS）、分钟（MINUTES）、毫秒（MILLISECONDS）、微秒（MICROSECONDS，千分之一毫秒）和纳秒（NANOSECONDS，千分之一微秒）。

5 workQueue(任务队列) : 用于保存等待执行的任务的阻塞队列。可以选择以下几个阻塞队列：

ArrayBlockingQueue:是一个基于数组结构的有界阻塞队列，按FIFO原则进行排序
LinkedBlockingQueue:一个基于链表结构的阻塞队列，吞吐量高于ArrayBlockingQueue。静态工厂方法Excutors.newFixedThreadPool()使用了这个队列
SynchronousQueue: 一个不存储元素的阻塞队列。每个插入操作必须等到另一个线程调用移除操作，否则插入操作一直处于阻塞状态，吞吐量高于LinkedBlockingQueue，静态工厂方法Excutors.newCachedThreadPool()使用了这个队列
PriorityBlockingQueue:一个具有优先级的无限阻塞队列。

6 threadFactory（线程工厂）：可以通过线程工厂为每个创建出来的线程设置更有意义的名字，如开源框架guava

7 RejectedExecutionHandler （饱和策略）：当队列和线程池都满了，说明线程池处于饱和状态，那么必须采取一种策略还处理新提交的任务。它可以有如下四个选项：

AbortPolicy:直接抛出异常，默认情况下采用这种策略
CallerRunsPolicy:只用调用者所在线程来运行任务
DiscardOldestPolicy:丢弃队列里最近的一个任务，并执行当前任务
DiscardPolicy:不处理，丢弃掉

更多的时候，我们应该通过实现RejectedExecutionHandler 接口来自定义策略，比如记录日志或持久化存储等。

提交任务的方式：使用execute或者submit向线程池提交任务

1，execute方法用于提交不需要返回值的任务，利用这种方式提交的任务无法知道任务是否正常执行；

2，submit用于提交一个任务并带有返回值，这个方法将返回一个Future对象，可以通过这个返回对象判断任务是否执行成功，并且可以通过Future.get方法来获取返回值，get()方法会阻塞当前线程知道任务完成。

class ProcessorThread implements Runnable{
    private String str;
    ProcessorThread(String string){
      this.str= string;
    }

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

ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5,5,2, TimeUnit.MINUTES,new LinkedBlockingDeque());
String str=“hello world”;
//threadPoolExecutor.execute(new ProcessorThread(str)); // execute
threadPoolExecutor.submit(new ProcessorThread(str));// submit 
threadPoolExecutor.submit(new ProcessorThread(str)).get();// submit + get
//get方法会阻塞当前线程，知道线程执行完毕。

通过以上两种方式都可以实现多线程任务。

关闭线程池：threadPoolExecutor.shutdown()。或者 threadPoolExecutor.shutdownNow()。

使用ThreadPoolExecutor进行多线程编程

标签：proc override 大于 reads cut process tor this 接口

原文地址：https://www.cnblogs.com/fpqi/p/9719874.html

上一篇：ZooKeeper连接并创建节点以及实现分布式锁操作节点排序输出最小节点Demo

下一篇：springboot 使用传统方式部署

文章来自：搜素材网的编程语言模块，转载请注明文章出处。
文章标题：使用ThreadPoolExecutor进行多线程编程
文章链接：http://soscw.com/index.php/essay/95117.html

亲，登录后才可以留言！

使用ThreadPoolExecutor进行多线程编程

评论

热门文章

推荐文章

最新文章

置顶文章