public class Workers extends Object
Constructor and Description |
---|
Workers() |
Modifier and Type | Method and Description |
---|---|
static <IN,OUT> Worker<IN,OUT> |
add(String workerId,
int inputQueueLimit,
int outputQueueLimit,
org.rapidoid.lambda.Mapper<IN,OUT> mapper) |
static int |
count() |
static boolean |
enqueue(String workerId,
Object task,
boolean blocking) |
static <IN,OUT> Worker<IN,OUT> |
get(String workerId) |
Copyright © 2014–2015 Nikolche Mihajlovski and contributors. All rights reserved.