public final class PortActionHelper extends Object
Modifier and Type | Method and Description |
---|---|
static <T extends AbstractStage> |
checkBlockingForPendingPortActionRequest(T stage,
BlockingQueue<PortAction<T>> portActions) |
static <T extends AbstractStage> |
checkForPendingPortActionRequest(T stage,
BlockingQueue<PortAction<T>> portActions) |
static <T> BlockingQueue<T> |
createPortActionQueue() |
public static <T> BlockingQueue<T> createPortActionQueue()
public static <T extends AbstractStage> PortAction<T> checkForPendingPortActionRequest(T stage, BlockingQueue<PortAction<T>> portActions)
public static <T extends AbstractStage> void checkBlockingForPendingPortActionRequest(T stage, BlockingQueue<PortAction<T>> portActions) throws InterruptedException
InterruptedException
Copyright © 2015–2020. All rights reserved.