Package | Description |
---|---|
teetime.stage.basic.distributor.dynamic | |
teetime.stage.basic.merger.dynamic | |
teetime.util.framework.port |
Modifier and Type | Class and Description |
---|---|
class |
CreatePortActionDistributor<T> |
class |
RemovePortActionDistributor<T> |
Modifier and Type | Field and Description |
---|---|
protected BlockingQueue<PortAction<DynamicDistributor<T>>> |
DynamicDistributor.portActions |
Modifier and Type | Method and Description |
---|---|
boolean |
DynamicDistributor.addPortActionRequest(PortAction<DynamicDistributor<T>> newPortActionRequest) |
Modifier and Type | Class and Description |
---|---|
class |
CreatePortAction<T>
Deprecated.
since 3.0. Use
CreatePortActionMerger instead. |
class |
CreatePortActionMerger<T> |
class |
DoNothingPortAction<T> |
class |
RemovePortAction<T> |
Modifier and Type | Field and Description |
---|---|
protected BlockingQueue<PortAction<DynamicMerger<T>>> |
DynamicMerger.portActions |
Modifier and Type | Method and Description |
---|---|
boolean |
DynamicMerger.addPortActionRequest(PortAction<DynamicMerger<T>> newPortActionRequest) |
Modifier and Type | Method and Description |
---|---|
static <T extends AbstractStage> |
PortActionHelper.checkForPendingPortActionRequest(T stage,
BlockingQueue<PortAction<T>> portActions) |
Modifier and Type | Method and Description |
---|---|
static <T extends AbstractStage> |
PortActionHelper.checkBlockingForPendingPortActionRequest(T stage,
BlockingQueue<PortAction<T>> portActions) |
static <T extends AbstractStage> |
PortActionHelper.checkForPendingPortActionRequest(T stage,
BlockingQueue<PortAction<T>> portActions) |
Copyright © 2015–2020. All rights reserved.