|
@@ -19,17 +19,17 @@ public final class ThreadPoolFactory {
|
|
|
new ThreadFactoryBuilder().setNameFormat("DEFAULT-%d").build(),
|
|
new ThreadFactoryBuilder().setNameFormat("DEFAULT-%d").build(),
|
|
|
new ThreadPoolExecutor.AbortPolicy());
|
|
new ThreadPoolExecutor.AbortPolicy());
|
|
|
public final static ExecutorService RECALL = new CommonThreadPoolExecutor(
|
|
public final static ExecutorService RECALL = new CommonThreadPoolExecutor(
|
|
|
- 256,
|
|
|
|
|
- 256,
|
|
|
|
|
|
|
+ 320,
|
|
|
|
|
+ 320,
|
|
|
0L, TimeUnit.SECONDS,
|
|
0L, TimeUnit.SECONDS,
|
|
|
- new LinkedBlockingQueue<>(1000),
|
|
|
|
|
|
|
+ new LinkedBlockingQueue<>(5000),
|
|
|
new ThreadFactoryBuilder().setNameFormat("RecallService-%d").build(),
|
|
new ThreadFactoryBuilder().setNameFormat("RecallService-%d").build(),
|
|
|
new ThreadPoolExecutor.AbortPolicy());
|
|
new ThreadPoolExecutor.AbortPolicy());
|
|
|
private final static ExecutorService FILTER = new CommonThreadPoolExecutor(
|
|
private final static ExecutorService FILTER = new CommonThreadPoolExecutor(
|
|
|
- 256,
|
|
|
|
|
- 256,
|
|
|
|
|
|
|
+ 320,
|
|
|
|
|
+ 320,
|
|
|
0L, TimeUnit.SECONDS,
|
|
0L, TimeUnit.SECONDS,
|
|
|
- new LinkedBlockingQueue<>(1000),
|
|
|
|
|
|
|
+ new LinkedBlockingQueue<>(5000),
|
|
|
new ThreadFactoryBuilder().setNameFormat("FilterService-%d").build(),
|
|
new ThreadFactoryBuilder().setNameFormat("FilterService-%d").build(),
|
|
|
new ThreadPoolExecutor.AbortPolicy());
|
|
new ThreadPoolExecutor.AbortPolicy());
|
|
|
|
|
|