public class WorkerIO extends Object
| Constructor and Description |
|---|
WorkerIO(String id,
Process process,
IWorkerProcess wp) |
| Modifier and Type | Method and Description |
|---|---|
void |
close(boolean sync) |
void |
decouple() |
Map<String,Serializable> |
sendMessage(Map<String,Serializable> args,
long timeout) |
void |
waitFor(long timeout)
spend some time waiting for termination
|
public WorkerIO(String id, Process process, IWorkerProcess wp)
id - process - public void decouple()
public void close(boolean sync)
public void waitFor(long timeout)
timeout - public Map<String,Serializable> sendMessage(Map<String,Serializable> args, long timeout) throws IOException
IOException