net.sf.taverna.t2.workflowmodel.Processor.getDispatchStack()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(8.5k)|赞(0)|评价(0)|浏览(100)

本文整理了Java中net.sf.taverna.t2.workflowmodel.Processor.getDispatchStack()方法的一些代码示例，展示了Processor.getDispatchStack()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Processor.getDispatchStack()方法的具体详情如下：
包路径：net.sf.taverna.t2.workflowmodel.Processor
类名称：Processor
方法名：getDispatchStack

Processor.getDispatchStack介绍

[英]The dispatch stack pulls jobs from the queue generated by the iteration system and handles the dispatch of these jobs to appropriate activity workers
[中]分派堆栈从迭代系统生成的队列中提取作业，并将这些作业分派给适当的活动工作者

代码示例

代码示例来源：origin: net.sf.taverna.t2.ui-exts/loop-ui

public boolean canAddLayerFor(Processor proc) {
  DispatchStack dispatchStack = proc.getDispatchStack();
  for (DispatchLayer<?> layer : dispatchStack.getLayers()) {
    if (layer instanceof Loop) {
      return false;
    }
  }
  // Not found
  return true;
}

代码示例来源：origin: net.sf.taverna.t2.ui-exts/loop-ui

public static Loop getLoopLayer(Processor p) {
  Loop result = null;
  for (DispatchLayer dl : p.getDispatchStack().getLayers()) {
    if (dl instanceof Loop) {
      result = (Loop) dl;
      break;
    }
  }
  return result;
}

代码示例来源：origin: net.sf.taverna.t2.core/workflowmodel-core-extensions

protected IntermediateProvenance findIntermediateProvenance() {
  List<DispatchLayer<?>> layers = getProcessor().getDispatchStack().getLayers();
  for (DispatchLayer<?> layer : layers) {
    if (layer instanceof IntermediateProvenance) {
      return (IntermediateProvenance) layer;
    }
  }
  return null;
}

代码示例来源：origin: net.sf.taverna.t2.workbench/contextual-views-impl

public void actionPerformed(ActionEvent e) {
    Edit<DispatchStack> deleteEdit = edits.getDeleteDispatchLayerEdit(
        processor.getDispatchStack(), layer);
    // TODO: Should warn before removing "essential" layers
    try {
      editManager.doDataflowEdit(fileManager.getCurrentDataflow(),
          deleteEdit);
    } catch (EditException ex) {
      logger.warn("Could not remove layer " + layer, ex);
    }
  }
}

代码示例来源：origin: net.sf.taverna.t2.core/workflowmodel-impl

@SuppressWarnings("unchecked")
  public void deserializeDispatchStack(Processor processor,
      Element dispatchStack) throws ClassNotFoundException, InstantiationException, IllegalAccessException, EditException {
    int layers=0;
    for (Element layer : (List<Element>)dispatchStack.getChildren(DISPATCH_LAYER,T2_WORKFLOW_NAMESPACE)) {
      DispatchLayer<?> dispatchLayer = DispatchLayerXMLDeserializer.getInstance().deserializeDispatchLayer(layer);
      if (dispatchLayer instanceof Invoke) {
        edits.getAddDispatchLayerEdit(processor.getDispatchStack(), new Stop(), layers++).doEdit();
      }
      edits.getAddDispatchLayerEdit(processor.getDispatchStack(), dispatchLayer, layers++).doEdit();
    }
    
  }
}

代码示例来源：origin: net.sf.taverna.t2/workflowmodel-impl

@SuppressWarnings("unchecked")
  public void deserializeDispatchStack(Processor processor,
      Element dispatchStack) throws ClassNotFoundException, InstantiationException, IllegalAccessException, EditException {
    int layers=0;
    for (Element layer : (List<Element>)dispatchStack.getChildren(DISPATCH_LAYER,T2_WORKFLOW_NAMESPACE)) {
      DispatchLayer<?> dispatchLayer = DispatchLayerXMLDeserializer.getInstance().deserializeDispatchLayer(layer);
      edits.getAddDispatchLayerEdit(processor.getDispatchStack(), dispatchLayer, layers++).doEdit();
    }
    
  }
}

代码示例来源：origin: net.sf.taverna.t2.ui-components/contextual-views

public void actionPerformed(ActionEvent e) {
    Edit<DispatchStack> deleteEdit = edits.getDeleteDispatchLayerEdit(
        processor.getDispatchStack(), layer);
    // TODO: Should warn before removing "essential" layers
    try {
      editManager.doDataflowEdit(fileManager.getCurrentDataflow(),
          deleteEdit);
      refreshView();
    } catch (EditException ex) {
      logger.warn("Could not remove layer " + layer, ex);
    }
  }
}

代码示例来源：origin: net.sf.taverna.t2.ui-exts/loop-ui

public Loop findLoopLayer() throws EditException {
  DispatchStack dispatchStack = processor.getDispatchStack();
  Loop loopLayer = null;
  for (DispatchLayer<?> layer : dispatchStack.getLayers()) {
    if (layer instanceof Loop) {
      loopLayer = (Loop) layer;
    }
  }
  if (loopLayer == null) {
    loopLayer = new Loop();
    insertLoopLayer(dispatchStack, loopLayer);
  }
  return loopLayer;
}

代码示例来源：origin: net.sf.taverna.t2.workbench/contextual-views-impl

gbc.weightx = 0.1;
List<DispatchLayer<?>> layers = processor.getDispatchStack()
    .getLayers();
for (DispatchLayer<?> layer : layers) {

代码示例来源：origin: net.sf.taverna.t2/workflowmodel-impl

protected Element processorToXML(Processor processor) throws IOException,
    JDOMException {
  Element result = new Element(PROCESSOR, T2_WORKFLOW_NAMESPACE);
  Element nameElement = new Element(NAME, T2_WORKFLOW_NAMESPACE);
  nameElement.setText(processor.getLocalName());
  result.addContent(nameElement);
  // input and output ports
  Element inputPorts = processorInputPortsToXML(processor);
  Element outputPorts = processorOutputPortsToXML(processor);
  result.addContent(inputPorts);
  result.addContent(outputPorts);
  // annotations
  result.addContent(annotationsToXML(processor));
  // list of activities
  Element activities = new Element(ACTIVITIES, T2_WORKFLOW_NAMESPACE);
  for (Activity<?> activity : processor.getActivityList()) {
    activities.addContent(activityToXML(activity));
  }
  result.addContent(activities);
  // dispatch stack
  result.addContent(dispatchStackToXML(processor.getDispatchStack()));
  // iteration strategy
  result.addContent(iterationStrategyStackToXML(processor
      .getIterationStrategy()));
  return result;
}

代码示例来源：origin: net.sf.taverna.t2.ui-components/contextual-views

gbc.weightx = 0.1;
List<DispatchLayer<?>> layers = processor.getDispatchStack()
    .getLayers();
for (DispatchLayer<?> layer : layers) {

代码示例来源：origin: net.sf.taverna.t2.core/workflowmodel-impl

public Element processorToXML(Processor processor) throws IOException,
    JDOMException {
  Element result = new Element(PROCESSOR, T2_WORKFLOW_NAMESPACE);
  Element nameElement = new Element(NAME, T2_WORKFLOW_NAMESPACE);
  nameElement.setText(processor.getLocalName());
  result.addContent(nameElement);
  // input and output ports
  Element inputPorts = processorInputPortsToXML(processor);
  Element outputPorts = processorOutputPortsToXML(processor);
  result.addContent(inputPorts);
  result.addContent(outputPorts);
  // annotations
  result.addContent(annotationsToXML(processor));
  // list of activities
  Element activities = new Element(ACTIVITIES, T2_WORKFLOW_NAMESPACE);
  for (Activity<?> activity : processor.getActivityList()) {
    activities.addContent(activityToXML(activity));
  }
  result.addContent(activities);
  // dispatch stack
  result.addContent(dispatchStackToXML(processor.getDispatchStack()));
  // iteration strategy
  result.addContent(iterationStrategyStackToXML(processor
      .getIterationStrategy()));
  return result;
}

代码示例来源：origin: net.sf.taverna.t2.ui-exts/loop-ui

public void actionPerformed(ActionEvent e) {
    Processor p = (Processor) getContextualSelection().getSelection();
      Loop loopLayer = LoopConfigureMenuAction.getLoopLayer(p);
      Edit<DispatchStack> deleteEdit = edits.getDeleteDispatchLayerEdit(
          p.getDispatchStack(), loopLayer);
      // TODO: Should warn before removing "essential" layers
      try {
        editManager.doDataflowEdit(fileManager.getCurrentDataflow(),
            deleteEdit);
      } catch (EditException ex) {
        logger.warn("Could not remove layer " + loopLayer, ex);
      }
    
  }
};

代码示例来源：origin: net.sf.taverna.t2.ui-exts/retry-ui

public void actionPerformed(ActionEvent e) {
    Retry retryLayer = null;
    Processor p = (Processor) getContextualSelection().getSelection();
    for (DispatchLayer dl : p.getDispatchStack().getLayers()) {
      if (dl instanceof Retry) {
        retryLayer = (Retry) dl;
        break;
      }
    }
    if (retryLayer != null) {
    RetryConfigureAction retryConfigureAction = new RetryConfigureAction(null, null, retryLayer);
    retryConfigureAction.actionPerformed(e);
    }
  }
};

代码示例来源：origin: net.sf.taverna.t2.core/workflowmodel-impl

private void addProvenanceLayerToProcessors(Dataflow dataflow2, WorkflowProvenanceItem workflowItem) {
  for (Processor processor : dataflow.getProcessors()) {
    DispatchStack dispatchStack = processor.getDispatchStack();
    List<DispatchLayer<?>> layers = dispatchStack.getLayers();
    boolean provAlreadyAdded = false;

代码示例来源：origin: net.sf.taverna.t2/workflowmodel-impl

private void addProvenanceLayerToProcessors(Dataflow dataflow2, WorkflowProvenanceItem workflowItem) {
  for (Processor processor : dataflow.getProcessors()) {
    DispatchStack dispatchStack = processor.getDispatchStack();
    List<DispatchLayer<?>> layers = dispatchStack.getLayers();
    boolean provAlreadyAdded = false;

代码示例来源：origin: net.sf.taverna.t2/cyclone-impl

addDispatchLayers(t1Processor, t2Processor.getDispatchStack());

代码示例来源：origin: net.sf.taverna.t2/compatibility-impl

addDispatchLayers(t1Processor, t2Processor.getDispatchStack());

代码示例来源：origin: net.sf.taverna.t2/cyclone-impl

.getDispatchStack().getLayers();
assertEquals(5, dispatchLayers.size());
assertTrue(dispatchLayers.get(0) instanceof Parallelize);

代码示例来源：origin: net.sf.taverna.t2.compatibility/compatibility-impl

.getDispatchStack().getLayers();
assertEquals(6, dispatchLayers.size());
assertTrue(dispatchLayers.get(0) instanceof Parallelize);

内容来源于网络，如有侵权，请联系作者删除！

Processor

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com