|
|
|
@ -50,11 +50,11 @@ public class RedisStreamConsumer { |
|
|
|
|
|
|
|
private final ExecutorService workerExecutor = |
|
|
|
new ThreadPoolExecutor( |
|
|
|
32, |
|
|
|
128, |
|
|
|
16, |
|
|
|
64, |
|
|
|
60, |
|
|
|
TimeUnit.SECONDS, |
|
|
|
new LinkedBlockingQueue<>(20000), |
|
|
|
new LinkedBlockingQueue<>(10000), |
|
|
|
new ThreadPoolExecutor.CallerRunsPolicy() |
|
|
|
); |
|
|
|
|
|
|
|
|