// 创建一个线程池,根据CPU核心数来创建 int corePoolSize = Runtime.getRuntime().availableProcessors(); ExecutorService executorService = Executors.newFixedThreadPool(corePoolSize); // 将任务拆分成多个子任务 List<List<UserEo>> subUserEoList = ListUtils.splitList(userEoList, corePoolSize); // 提交子任务到线程池中执行 for (List<UserEo> subList : subUserEoList) { executorService.execute(() -> { for (UserEo userEo : subList) { List<DataPermissionSchema> userDataPermissionSchema = getUserDataPermissionSchema(userEo.getUserUid(), userEo.getOrgCode()); redisTemplate.opsForValue().set(SystemsConstant.DATA_PERMISSION_SCHEMA + userEo.getUserUid(), ObjectUtil.toString(userDataPermissionSchema)); } });} // 关闭线程池 executorService.shutdown();编译错误说手动创建线程池更好
时间: 2024-02-03 12:11:36 浏览: 118
Executor,Executors,ExecutorService比较.docx
手动创建线程池确实比使用Executors类中提供的静态方法更好。这是因为Executors类中的静态方法可能会使用一些默认的配置,这些配置并不一定适用于你的具体场景。另外,手动创建线程池可以让你更好地控制线程池的参数,以便更好地适应你的具体需求。
以下是手动创建线程池的示例代码:
```java
int corePoolSize = Runtime.getRuntime().availableProcessors();
ThreadPoolExecutor executor = new ThreadPoolExecutor(
corePoolSize, // 核心线程数
corePoolSize, // 最大线程数
0L, TimeUnit.MILLISECONDS, // 空闲线程存活时间
new LinkedBlockingQueue<Runnable>(), // 任务队列
Executors.defaultThreadFactory(), // 线程工厂
new ThreadPoolExecutor.AbortPolicy() // 拒绝策略
);
```
在这个示例中,我们使用了ThreadPoolExecutor类来手动创建线程池。它的构造函数需要传入一些参数,包括核心线程数、最大线程数、任务队列、线程工厂和拒绝策略等。你可以根据自己的需求来设置这些参数。
阅读全文