com.evolveum.midpoint.task.api.Task.getLightweightAsynchronousSubtasks()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(3.3k)|赞(0)|评价(0)|浏览(72)

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

Task.getLightweightAsynchronousSubtasks介绍

暂无

代码示例

代码示例来源:origin: Evolveum/midpoint

public Collection<Task> getTransientSubtasks(TaskQuartzImpl task) {
  List<Task> retval = new ArrayList<>();
  Task runningInstance = locallyRunningTaskInstancesMap.get(task.getTaskIdentifier());
  if (runningInstance != null) {
    retval.addAll(runningInstance.getLightweightAsynchronousSubtasks());
  }
  return retval;
}

代码示例来源:origin: Evolveum/midpoint

public static void appendLastFailuresInformation(String operationNamePrefix, Task task, OperationResult result) {
  appendLastFailuresInformation(operationNamePrefix, task, false, result);
  for (Task subtask : task.getLightweightAsynchronousSubtasks()) {
    appendLastFailuresInformation(operationNamePrefix, subtask, true, result);
  }
}
private static void appendLastFailuresInformation(String operationNamePrefix, Task task, boolean subtask, OperationResult result) {

代码示例来源:origin: Evolveum/midpoint

@Test
public void test100LightweightSubtasks() throws Exception {
  final String TEST_NAME = "test100LightweightSubtasks";
  final OperationResult result = createResult(TEST_NAME, LOGGER);
  addObjectFromFile(taskFilename(TEST_NAME));
  Task task = getTask(taskOid(TEST_NAME), result);
  System.out.println("After setup: " + task.debugDump());
  waitForTaskClose(taskOid(TEST_NAME), result, 15000, 500);
  task.refresh(result);
  System.out.println("After refresh (task was executed): " + task.debugDump());
  Collection<? extends Task> subtasks = parallelTaskHandler.getLastTaskExecuted().getLightweightAsynchronousSubtasks();
  assertEquals("Wrong number of subtasks", MockParallelTaskHandler.NUM_SUBTASKS, subtasks.size());
  for (Task subtask : subtasks) {
    assertEquals("Wrong subtask state", TaskExecutionStatus.CLOSED, subtask.getExecutionStatus());
    MockParallelTaskHandler.MyLightweightTaskHandler handler = (MockParallelTaskHandler.MyLightweightTaskHandler) subtask.getLightweightTaskHandler();
    assertTrue("Handler has not run", handler.hasRun());
    assertTrue("Handler has not exited", handler.hasExited());
  }
}

代码示例来源:origin: Evolveum/midpoint

AssertJUnit.assertEquals("Task is not suspended", TaskExecutionStatus.SUSPENDED, task.getExecutionStatus());
Collection<? extends Task> subtasks = parallelTaskHandler.getLastTaskExecuted().getLightweightAsynchronousSubtasks();
assertEquals("Wrong number of subtasks", MockParallelTaskHandler.NUM_SUBTASKS, subtasks.size());
for (Task subtask : subtasks) {

代码示例来源:origin: Evolveum/midpoint

assertTrue("Subtask is not a LAT", subtask.isLightweightAsynchronousTask());
assertEquals("Subtask has a wrong lightweight handler", handler, subtask.getLightweightTaskHandler());
assertTrue("Subtask is not in LAT list of parent", task.getLightweightAsynchronousSubtasks().contains(subtask));
assertFalse("Subtask is in Running LAT list of parent", task.getRunningLightweightAsynchronousSubtasks().contains(subtask));
assertFalse("Subtask is marked as already started", subtask.lightweightHandlerStartRequested());

相关文章

微信公众号

最新文章

更多