1 | package felix.society; |
2 | |
3 | import java.util.ArrayList; |
4 | import java.util.concurrent.ExecutorService; |
5 | |
6 | import felix.society.Task.TaskType; |
7 | |
8 | /** |
9 | * TaskList -- Subtasks in it must be executed in order, |
10 | * and the downstream tasks can be executed only if |
11 | * the upstream tasks are joined. |
12 | * @author czhang |
13 | * |
14 | */ |
15 | public class TaskList extends Task{ |
16 | |
17 | public TaskList(){ |
18 | super(TaskType.TASKLIST); |
19 | } |
20 | |
21 | public TaskList(int _nRuns){ |
22 | super(TaskType.TASKLIST, _nRuns); |
23 | } |
24 | |
25 | @Override |
26 | public Worker generateWorker(){ |
27 | return null; |
28 | } |
29 | |
30 | public Worker generateWorker(ExecutorService pool) { |
31 | return new TaskListExecutionWorker(this.subTasks, pool); |
32 | } |
33 | |
34 | /** |
35 | * Worker for running this TaskList. |
36 | * @author czhang |
37 | * |
38 | */ |
39 | public class TaskListExecutionWorker extends Worker{ |
40 | |
41 | ArrayList<Task> subtasks; |
42 | ExecutorService pool; |
43 | |
44 | public TaskListExecutionWorker(ArrayList<Task> _subtasks, |
45 | ExecutorService _pool){ |
46 | subtasks = _subtasks; |
47 | pool = _pool; |
48 | } |
49 | |
50 | @Override |
51 | public void run() { |
52 | |
53 | try{ |
54 | for(Task t : subTasks){ |
55 | if(t.getType() == TaskType.TASK){ |
56 | currentWorker = t.generateWorker(); |
57 | currentFuture = pool.submit(currentWorker); |
58 | currentFuture.get(); |
59 | }else{ |
60 | currentWorker = t.generateWorker(pool); |
61 | currentFuture = softpool.submit(currentWorker); |
62 | currentFuture.get(); |
63 | } |
64 | } |
65 | }catch(Exception e){ |
66 | submitException(e); |
67 | } |
68 | } |
69 | |
70 | } |
71 | |
72 | } |
73 | |
74 | |
75 | |
76 | |
77 | |
78 | |
79 | |
80 | |
81 | |
82 | |