1. 流程觸發
execution exe = runtimeservice.createexecutionquery()
.processinstanceid(pi.getid())
.onlychildexecutions().singleresult();
system.out.println("流程的當前節點："+exe.getactivityid());
runtimeservice.trigger(exe.getid()); //觸發以後流程會流轉到下乙個節點
2. 觸發訊號事件
捕獲事件（catching） 當流程到達捕獲事件節點時，會等待外界的訊號，然後再觸發事件
丟擲事件（throwing） 當流程到達這個節點時，會直接丟擲事件
3. 建立帶有捕獲事件的bpmn檔案，建立好後，以xml格式開啟bpmn檔案，在裡面新增捕獲事件標記，當到達這個事件節點時，給它發乙個訊號
runservice.signaleventreceived("testsignal"); //觸發訊號 ，流程到下一節點
spark streaming任務觸發執行時間
相信有不少小夥伴在使用spark streaming做微批次處理的時候有過疑問，就是我設定了duration然後啟動任務，那麼我的批次任務每次會在啥時候啟動呢？相信對於duration設定比較小的同學來說並不會關心在什麼時候執行，但是對於duration設定比較大或者對資料延時 資源敏感的同學來說，...
Python併發執行
使用map簡化併發的複雜度，生產者消費者模型實在看的頭疼 參考這篇帖子說明的很清楚 from multiprocessing.dummy import pool as threadpool import requests import time urls 定義網頁資源集合 for i in rang...
Go 併發執行
需要併發執行的場景有很多 爬蟲 拉取資料 更新資料 go作為天生高併發的語言，在使用併發時是比較方便的。package main import fmt func main description 開啟多執行緒執行 param total 啟動執行緒數 param work 需要執行的方法 func ...