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 |
setReadMaxBytesPerRound(int readMaxBytesPerRound) |
void |
setReadMaxTimesPerRound(int readMaxTimesPerRound) |
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)
public void setReadMaxTimesPerRound(int readMaxTimesPerRound)
public void setReadMaxBytesPerRound(int readMaxBytesPerRound)
Copyright © 2021. All Rights Reserved.