diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/manage/PullTodoBroadcaster.java b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/manage/PullTodoBroadcaster.java index 7aa43286..b74db7ef 100644 --- a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/manage/PullTodoBroadcaster.java +++ b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/manage/PullTodoBroadcaster.java @@ -29,9 +29,9 @@ class PullTodoBroadcaster implements DisposableBean { private final MessageApi messageApi; private final ExecutorService executor = new ThreadPoolExecutor( - 1, 5, + 20, 40, 5, TimeUnit.MINUTES, - new ArrayBlockingQueue<>(50), + new ArrayBlockingQueue<>(2000), new NamedThreadFactory("PullTodoBroadcaster", false)); /**