发布事件代码提交
This commit is contained in:
parent
4c1e931f11
commit
03de15b0a4
Binary file not shown.
@ -123,7 +123,7 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
|
|||||||
|
|
||||||
|
|
||||||
//更新任务状态
|
//更新任务状态
|
||||||
int r1 = DBSql.update("UPDATE BO_ACT_EXECUTIVE_TASK SET ISTASKEND='2' WHERE TASKID ='" + ext.getProcessInstance().getId() + "'");
|
int r1 = DBSql.update("UPDATE BO_ACT_EXECUTIVE_TASK SET ISTASKEND='2' WHERE TASKID='" + ext.getProcessInstance().getId() + "'");
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
@ -599,7 +599,7 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
|
|||||||
// 创建线程来实现为每100人为一个的线程跑待阅
|
// 创建线程来实现为每100人为一个的线程跑待阅
|
||||||
ProcessInstance instanceById = processExecutionContext.getProcessInstance();
|
ProcessInstance instanceById = processExecutionContext.getProcessInstance();
|
||||||
CountDownLatch countDownLatch = new CountDownLatch(list.size());
|
CountDownLatch countDownLatch = new CountDownLatch(list.size());
|
||||||
ExecutorService service = Executors.newFixedThreadPool(8);
|
ExecutorService service = Executors.newFixedThreadPool(4);
|
||||||
int m = 0;
|
int m = 0;
|
||||||
for (String[] resrt:list
|
for (String[] resrt:list
|
||||||
) {
|
) {
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user