Class StageManager

java.lang.Object

io.nosqlbench.virtdata.userlibs.apps.summarizer.StageManager

All Implemented Interfaces:

Runnable, Thread.UncaughtExceptionHandler

public class StageManager
extends Object
implements Thread.UncaughtExceptionHandler, Runnable

Constructor Summary

Constructors

Constructor	Description
StageManager(int threads, IntFunction<Runnable> tasks)

Method Summary

Modifier and Type	Method	Description
void	coordinateFor(int concurrency, String forWhat)
void	OnYourMarkGetSet(Object forWhat)
void	run()
void	uncaughtException(Thread t, Throwable e)

Methods inherited from class java.lang.Object

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

Constructor Details

StageManager

public StageManager(int threads,
 IntFunction<Runnable> tasks)

Method Details

run

public void run()

Specified by:

run in interface Runnable

OnYourMarkGetSet

public void OnYourMarkGetSet(Object forWhat)

coordinateFor

public void coordinateFor(int concurrency,
 String forWhat)

uncaughtException

public void uncaughtException(Thread t,
 Throwable e)

Specified by:

uncaughtException in interface Thread.UncaughtExceptionHandler