org.dice_research.topicmodeling.concurrent.join

Class SimpleTaskJoin.JoiningObserver

java.lang.Object

org.dice_research.topicmodeling.concurrent.join.SimpleTaskJoin.JoiningObserver

All Implemented Interfaces:

TaskObserver

Enclosing class:

SimpleTaskJoin

protected static class SimpleTaskJoin.JoiningObserver
extends Object
implements TaskObserver

Field Summary

Fields

Modifier and Type	Field and Description
private Semaphore	finishedTasksCount
private Overseer	overseer
private Semaphore	taskCountMutex

Constructor Summary

Constructors

Constructor and Description
JoiningObserver(Overseer overseer)

Method Summary

Modifier and Type	Method and Description
protected int	countActiveTasks()
void	reportTaskFinished(Task task)
void	reportTaskThrowedException(Task task, Throwable t)
void	waitForTasksToFinish()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

overseer

private Overseer overseer

taskCountMutex

private Semaphore taskCountMutex

finishedTasksCount

private Semaphore finishedTasksCount

Constructor Detail

JoiningObserver

public JoiningObserver(Overseer overseer)

Method Detail

reportTaskFinished

public void reportTaskFinished(Task task)

Specified by:

reportTaskFinished in interface TaskObserver

reportTaskThrowedException

public void reportTaskThrowedException(Task task,
                                       Throwable t)

Specified by:

reportTaskThrowedException in interface TaskObserver

waitForTasksToFinish

public void waitForTasksToFinish()
                          throws InterruptedException

Throws:

InterruptedException

countActiveTasks

protected int countActiveTasks()