Skip to content

Commit

Permalink
poolSize配置项修改为notifyPoolSize
Browse files Browse the repository at this point in the history
  • Loading branch information
ElliotChina committed Jul 3, 2023
1 parent 7b8f0ca commit 714a617
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -192,6 +192,6 @@ public static class TaskQueueConfig {
/**
* 线程池CorePoolSize.
*/
private int poolSize = 10;
private int notifyPoolSize = 10;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ public class NotifyServiceImpl implements NotifyService {

public NotifyServiceImpl(ProxyProperties properties) {
this.executor = new ThreadPoolTaskExecutor();
this.executor.setCorePoolSize(properties.getQueue().getPoolSize());
this.executor.setCorePoolSize(properties.getQueue().getNotifyPoolSize());
this.executor.setThreadNamePrefix("TaskNotify-");
this.executor.initialize();
}
Expand Down

0 comments on commit 714a617

Please sign in to comment.