1112131415161718192021
} public void beforeAwait(CyclicBarrier barrier) { JArmusController controller = getController(); int phase = controller.advance(barrier); controller.beforeAwait(barrier, phase); } public void afterAwait() { getController().afterAwait(); }
2425262728293031323334
} @Override public void beforeInvoke(ForkJoinTask<?> task) { JArmusController handler = getController(); handler.beforeAwait(task, 1); handler.beforeTask(); } @Override public void afterInvoke() {
4243444546474849505152
* @param task */ @Override public void beforeJoin(ForkJoinTask<?> task) { JArmusController handler = getController(); handler.beforeAwait(task, 1); } /** * After the blocking call */ @Override