org.globus.cog.karajan.workflow.events
Class WorkerSweeper

java.lang.Object
  org.globus.cog.karajan.workflow.events.WorkerSweeper

public class WorkerSweeper
extends Object

Nested Class Summary

class

WorkerSweeper.SweeperTask

Field Summary

static int	added
static int	DEFAULT_BUS_SWEEPER_CYCLE
static int	DEFAULT_INITIAL_WAIT
static int	DEFAULT_MAX_EVENT_TIME
static int	DEFAULT_REDUCE_CYCLE_COUNT
static int	textra

Constructor Summary

WorkerSweeper(WorkerManager manager)

Method Summary

protected boolean

isBlocked(EventWorker worker)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_BUS_SWEEPER_CYCLE

public static final int DEFAULT_BUS_SWEEPER_CYCLE

See Also:

Constant Field Values

DEFAULT_INITIAL_WAIT

public static final int DEFAULT_INITIAL_WAIT

See Also:

Constant Field Values

DEFAULT_REDUCE_CYCLE_COUNT

public static final int DEFAULT_REDUCE_CYCLE_COUNT

See Also:

Constant Field Values

DEFAULT_MAX_EVENT_TIME

public static final int DEFAULT_MAX_EVENT_TIME

See Also:

Constant Field Values

added

public static int added

textra

public static int textra

Constructor Detail

WorkerSweeper

public WorkerSweeper(WorkerManager manager)

Method Detail

isBlocked

protected boolean isBlocked(EventWorker worker)