protected static class SimpleTaskJoin.JoiningObserver extends Object implements TaskObserver
Modifier and Type | Field and Description |
---|---|
private Semaphore |
finishedTasksCount |
private Overseer |
overseer |
private Semaphore |
taskCountMutex |
Constructor and Description |
---|
SimpleTaskJoin.JoiningObserver(Overseer overseer) |
Modifier and Type | Method and Description |
---|---|
protected int |
countActiveTasks() |
void |
reportTaskFinished(Task task) |
void |
reportTaskThrowedException(Task task,
Throwable t) |
void |
waitForTasksToFinish() |
private Overseer overseer
private Semaphore taskCountMutex
private Semaphore finishedTasksCount
public SimpleTaskJoin.JoiningObserver(Overseer overseer)
public void reportTaskFinished(Task task)
reportTaskFinished
in interface TaskObserver
public void reportTaskThrowedException(Task task, Throwable t)
reportTaskThrowedException
in interface TaskObserver
public void waitForTasksToFinish() throws InterruptedException
InterruptedException
protected int countActiveTasks()
Copyright © 2015. All rights reserved.