You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Class clazz = powerJobSpringWorker.getClass();
var field = clazz.getDeclaredField("powerJobWorker");
field.setAccessible(true);
var worker = (PowerJobWorker) field.get(powerJobSpringWorker);
var workerClass = worker.getClass();
var engine = workerClass.getDeclaredField("remoteEngine");
engine.setAccessible(true);
var remoteEngine = (RemoteEngine) engine.get(worker);
remoteEngine.close();
我使用了如上代码试图达到这个需求。在实践中发现还是有问题
节点是下线了,但是运行中的任务数量一直没有减少
任务数量是使用了计数器, try final 来进行计数的
最终一直没有进入final 所以应该是和 server 断联, 然后 直接 线程终止了?
所以还是希望增加一个这个功能
用于发版时的长任务不中断, 比如我们有同步任务,一般这种同步任务会进行30分钟- 几个小时不等
增加work节点状态,标识只是不接收新任务
已接收的任务正常执行,不收影响,可能是个长任务,耗时1H这种的任务
work java代码提供修改此状态的代码,提供stop 和 resume 用于不接收新任务以及恢复任务接收
The text was updated successfully, but these errors were encountered: