xin.bluesky.leiothrix.worker.executor

类 TaskContainer

java.lang.Object

xin.bluesky.leiothrix.worker.executor.TaskContainer

public class TaskContainer
extends Object

作者:

张轲

方法概要

限定符和类型	方法和说明
static void	putPartitionTaskWrapper(PartitionTaskWrapper partitionTaskWrapper)
static PartitionTaskWrapper	takePartitionTaskWrapper(long timeout, TimeUnit timeUnit)

从类继承的方法 java.lang.Object

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

方法详细资料

takePartitionTaskWrapper

public static PartitionTaskWrapper takePartitionTaskWrapper(long timeout,
                                                            TimeUnit timeUnit)
                                                     throws InterruptedException

抛出:

InterruptedException

putPartitionTaskWrapper

public static void putPartitionTaskWrapper(PartitionTaskWrapper partitionTaskWrapper)