本文整理了Java中com.evolveum.midpoint.task.api.Task.getLightweightAsynchronousSubtasks()
方法的一些代码示例,展示了Task.getLightweightAsynchronousSubtasks()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Task.getLightweightAsynchronousSubtasks()
方法的具体详情如下:
包路径:com.evolveum.midpoint.task.api.Task
类名称: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());
内容来源于网络,如有侵权,请联系作者删除!