1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27 package gov.nist.secauto.decima.core.assessment;
28
29 import gov.nist.secauto.decima.core.assessment.result.AssessmentResultBuilder;
30 import gov.nist.secauto.decima.core.document.Document;
31
32 import org.apache.logging.log4j.LogManager;
33 import org.apache.logging.log4j.Logger;
34
35 import java.util.HashSet;
36 import java.util.List;
37 import java.util.Objects;
38 import java.util.Set;
39 import java.util.concurrent.Callable;
40 import java.util.concurrent.CompletionService;
41 import java.util.concurrent.ExecutionException;
42 import java.util.concurrent.Executor;
43 import java.util.concurrent.ExecutorCompletionService;
44 import java.util.concurrent.Future;
45
46 public class ConcurrentAssessmentExecutor<DOC extends Document>
47 extends AbstractAssessmentExecutor<DOC> {
48 private static final Logger log = LogManager.getLogger(ConcurrentAssessmentExecutor.class);
49 private final Executor executor;
50
51
52
53
54
55
56
57
58
59
60 public ConcurrentAssessmentExecutor(Executor executor, List<? extends Assessment<DOC>> assessments) {
61 super(assessments);
62 Objects.requireNonNull(executor, "executor");
63 this.executor = executor;
64 }
65
66 public Executor getExecutor() {
67 return executor;
68 }
69
70 @Override
71 protected final void executeInternal(DOC targetDocument, AssessmentResultBuilder builder) throws AssessmentException {
72 CompletionService<Void> completionService = new ExecutorCompletionService<>(executor);
73 Set<Future<Void>> futures = new HashSet<>();
74 for (Assessment<DOC> assessment : getExecutableAssessments(targetDocument)) {
75 log.info("Submitting assessment for execution: " + assessment.getName(true));
76 futures.add(completionService.submit(new AssessmentTask(assessment, targetDocument, builder)));
77 }
78
79 try {
80 while (!futures.isEmpty()) {
81 Future<Void> future = completionService.take();
82 futures.remove(future);
83 future.get();
84 }
85 } catch (InterruptedException e) {
86 throw new AssessmentException("the assessment execution was interrupted", e);
87 } catch (ExecutionException e) {
88 if (e.getCause() instanceof AssessmentException) {
89 throw (AssessmentException) e.getCause();
90 }
91 } finally {
92 for (Future<Void> future : futures) {
93 future.cancel(true);
94 }
95 }
96 }
97
98 private class AssessmentTask implements Callable<Void> {
99 private final Assessment<DOC> assessment;
100 private final DOC documentToAssess;
101 private final AssessmentResultBuilder builder;
102
103 public AssessmentTask(Assessment<DOC> assessment, DOC documentToAssess, AssessmentResultBuilder builder) {
104 Objects.requireNonNull(assessment, "assessment");
105 Objects.requireNonNull(documentToAssess, "documentToAssess");
106 Objects.requireNonNull(builder, "builder");
107 this.assessment = assessment;
108 this.documentToAssess = documentToAssess;
109 this.builder = builder;
110 }
111
112 @Override
113 public Void call() throws AssessmentException {
114 AssessmentExecutionHelper.executeAssessment(assessment, documentToAssess, builder);
115 return null;
116 }
117
118 }
119
120 }