private TaskThreadService taskService;
- private int thread_max_num = 100;
+ private int threadMaxNum = 100;
@Override
public void dispose() {
collectChannel = MessageChannelFactory.getMessageChannel(Constant.COLLECT_CHANNEL_KEY);
- taskService = TaskThreadService.getInstance(thread_max_num);
+ taskService = TaskThreadService.getInstance(threadMaxNum);
taskService.start();
while (isRun()) {
/**
- * @return the thread_max_num
+ * @return the threadMaxNum
*/
- public int getThread_max_num() {
- return thread_max_num;
+ public int getThreadMaxNum() {
+ return threadMaxNum;
}
/**
- * @param thread_max_num the thread_max_num to set
+ * @param threadMaxNum the threadMaxNum to set
*/
- public void setThread_max_num(int thread_max_num) {
- this.thread_max_num = thread_max_num;
+ public void setThreadMaxNum(int threadMaxNum) {
+ this.threadMaxNum = threadMaxNum;
}
col.setRun(true);
col.dispose();
col.getTaskService().stopTask();
- col.getThread_max_num();
- col.setThread_max_num(1);
+ col.getThreadMaxNum();
+ col.setThreadMaxNum(1);
}
col.setRun(true);
col.dispose();
col.getTaskService().stopTask();
- col.getThread_max_num();
- col.setThread_max_num(1);
+ col.getThreadMaxNum();
+ col.setThreadMaxNum(1);
}
}