newFixedThreadPool的阻塞队列大小是没有大小限制的,如果队列堆积数据太多会造成资源消耗。
newCachedThreadPool是线程数量是没有大小限制的,当新的线程来了直接创建,同样会造成资源消耗殆尽。
在新建线程池的时候使用ThreadPoolExecutor创建,阻塞队列可以使用ArrayBlockingQueue,这个队列的源码很金典,锁是一个成员变量。
成员变量在堆内存中
局部变量在栈内存保存
比较好用的线程池;
guava封装了很多实用的工具

<dependency>
   <groupId>com.google.guava</groupId>
   <artifactId>guava</artifactId>
   <version>18.0</version>
</dependency>
private final static int taskSize = 500;
public static final ListeningExecutorService servicePool = MoreExecutors
      .listeningDecorator(new ThreadPoolExecutor(
          100, 100, 60000L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>(taskSize)));

执行

ListenableFuture<JSONObject> future = ServicePool.singService
                .submit(() -> getdata(a,b,c));
try {
     JSONObject jsonObject = future.get();
 } catch (InterruptedException e) {
      e.printStackTrace();
 } catch (ExecutionException e) {
      e.printStackTrace();
 }

想了解更多java相关技术,请关注公众号“JavaEE那些事”

扫描下面二维码,更多技术资料等你来拿
这里写图片描述

GitHub 加速计划 / th / ThreadPool
7.74 K
2.22 K
下载
A simple C++11 Thread Pool implementation
最近提交(Master分支:2 个月前 )
9a42ec13 - 9 年前
fcc91415 - 9 年前
Logo

旨在为数千万中国开发者提供一个无缝且高效的云端环境,以支持学习、使用和贡献开源项目。

更多推荐