|
@@ -92,12 +92,7 @@ public class XxlJobExecutor {
|
92
|
92
|
}
|
93
|
93
|
jobThreadRepository.clear();
|
94
|
94
|
}
|
95
|
|
- if(jobHandlerRepository.size() >0 ){
|
96
|
|
- for (Map.Entry<String, IJobHandler> item: jobHandlerRepository.entrySet()){
|
97
|
|
- removeJobHandler(item.getKey(), "web container destroy and kill the jod handler");
|
98
|
|
- }
|
99
|
|
- jobHandlerRepository.clear();
|
100
|
|
- }
|
|
95
|
+ jobHandlerRepository.clear();
|
101
|
96
|
|
102
|
97
|
|
103
|
98
|
// destory JobLogFileCleanThread
|
|
@@ -110,13 +105,6 @@ public class XxlJobExecutor {
|
110
|
105
|
stopRpcProvider();
|
111
|
106
|
}
|
112
|
107
|
|
113
|
|
- private void removeJobHandler(String handlerId, String removeOldReason){
|
114
|
|
- IJobHandler oldJobHandler = jobHandlerRepository.remove(handlerId);
|
115
|
|
- if (oldJobHandler != null) {
|
116
|
|
- oldJobHandler.destroy();
|
117
|
|
- }
|
118
|
|
- }
|
119
|
|
-
|
120
|
108
|
|
121
|
109
|
// ---------------------- admin-client (rpc invoker) ----------------------
|
122
|
110
|
private static List<AdminBiz> adminBizList;
|