Constructor and Description |
---|
WorkerActivity(String id,
WorkerQueue<IN> input,
WorkerQueue<OUT> output,
org.rapidoid.lambda.Mapper<IN,OUT> mapper) |
Modifier and Type | Method and Description |
---|---|
boolean |
enqueue(IN task,
boolean blocking) |
protected void |
loop() |
OUT |
nextResult(boolean blocking) |
int |
pendingResultsCount() |
int |
pendingTasksCount() |
halt, run, shutdown, start
public WorkerActivity(String id, WorkerQueue<IN> input, WorkerQueue<OUT> output, org.rapidoid.lambda.Mapper<IN,OUT> mapper)
public boolean enqueue(IN task, boolean blocking)
public int pendingTasksCount()
pendingTasksCount
in interface Worker<IN,OUT>
public int pendingResultsCount()
pendingResultsCount
in interface Worker<IN,OUT>
public OUT nextResult(boolean blocking)
nextResult
in interface Worker<IN,OUT>
Copyright © 2014–2015 Nikolche Mihajlovski. All rights reserved.