public class TaskManager extends Object
Constructor and Description |
---|
TaskManager(ConnectionBean connectionBean,
int threads) |
Modifier and Type | Method and Description |
---|---|
void |
addListener(TaskResultListener taskResultListener) |
DigestInfo |
digest() |
TaskRPC |
getTaskRPC() |
void |
init(TaskRPC taskRPC) |
void |
notifyListeners(Number320 taskKey,
Map<Number160,Data> dataMap) |
void |
removeListener(TaskResultListener taskResultListener) |
void |
shutdown() |
int |
submitTask(Peer peer,
Number160 taskId,
Worker mapper,
Map<Number160,Data> data,
PeerAddress senderAddress,
boolean sign) |
TaskStatus |
taskStatus(Number320 taskKey) |
public TaskManager(ConnectionBean connectionBean, int threads)
public void addListener(TaskResultListener taskResultListener)
public void removeListener(TaskResultListener taskResultListener)
public void init(TaskRPC taskRPC)
public TaskRPC getTaskRPC()
public TaskStatus taskStatus(Number320 taskKey)
public int submitTask(Peer peer, Number160 taskId, Worker mapper, Map<Number160,Data> data, PeerAddress senderAddress, boolean sign)
public DigestInfo digest()
public void shutdown()
Copyright © 2013. All Rights Reserved.