public class ProcessDataPipeline extends Object implements Runnable
构造器和说明 |
---|
ProcessDataPipeline(ChannelConnect connect,
ExecutorService helperExecutor,
ThreadPoolExecutor readRecordsExecutor,
ThreadPoolExecutor processRecordsExecutor) |
ProcessDataPipeline(ChannelConnect connect,
ExecutorService helperExecutor,
ThreadPoolExecutor readRecordsExecutor,
ThreadPoolExecutor processRecordsExecutor,
Semaphore semaphore) |
限定符和类型 | 方法和说明 |
---|---|
ProcessDataBackoff |
getBackoff() |
Semaphore |
getSemaphore() |
void |
run() |
void |
setBackoff(ProcessDataBackoff backoff) |
void |
setSemaphore(Semaphore semaphore) |
public ProcessDataPipeline(ChannelConnect connect, ExecutorService helperExecutor, ThreadPoolExecutor readRecordsExecutor, ThreadPoolExecutor processRecordsExecutor)
public ProcessDataPipeline(ChannelConnect connect, ExecutorService helperExecutor, ThreadPoolExecutor readRecordsExecutor, ThreadPoolExecutor processRecordsExecutor, Semaphore semaphore)
public ProcessDataBackoff getBackoff()
public void setBackoff(ProcessDataBackoff backoff)
public Semaphore getSemaphore()
public void setSemaphore(Semaphore semaphore)
Copyright © 2019. All Rights Reserved.