Commit dead06df by guo_minglei@163.com

添加方法

parent 01afe49a
......@@ -11,20 +11,41 @@ public class FlowContentManager {
//存储当前的调度中心运行了哪些工作流(key为工作流名称加runid)
private static HashMap<String, FlowContent> flowContentHashMap = new HashMap<>(20);
/**
* 放置工作流运行内容
* @param flowKey
* @param flowContent
*/
public static synchronized void putFlowContent(String flowKey, FlowContent flowContent){
flowContentHashMap.put(flowKey, flowContent);
}
/**
* 移除工作流运行内容
* @param flowKey
* @return
*/
public static synchronized FlowContent remove(String flowKey){
FlowContent flowContent = flowContentHashMap.remove(flowKey);
return flowContent;
}
/**
* 获取工作流运行内容
* @param flowKey
* @return
*/
public static synchronized FlowContent getFlowContent(String flowKey){
FlowContent flowContent = flowContentHashMap.get(flowKey);
return flowContent;
}
/**
* 创建工作流运行内容主体
* @param flowKey
* @param allJobNum
* @return
*/
public static synchronized FlowContent createFlowContent(String flowKey, Integer allJobNum){
FlowContent flowContent = new FlowContent(flowKey, allJobNum);
return flowContent;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment