public class Scheduler extends Object
Constructor and Description |
---|
Scheduler(int maintenanceThreads,
int replicationThreads) |
Modifier and Type | Method and Description |
---|---|
void |
addConnectionQueue(FutureChannel futureChannelCreation,
Semaphore semaphore,
Runnable runnable) |
void |
addQueue(FutureRunnable futureRunnable) |
ScheduledExecutorService |
getScheduledExecutorServiceMaintenance() |
ScheduledExecutorService |
getScheduledExecutorServiceReplication() |
void |
keepTrack(PeerAddress remotePeer,
Number160 taskId,
TaskResultListener taskResultListener) |
void |
scheduleTimeout(BaseFuture baseFuture,
int millis,
String reason) |
void |
shutdown() |
void |
startDelayedChannelCreator() |
void |
startMaintainance(PeerMap peerMap,
HandshakeRPC handshakeRPC,
ConnectionReservation connectionReservation,
int max) |
void |
startTimeout() |
void |
startTracking(TaskRPC taskRPC,
ConnectionReservation connectionReservation) |
void |
stopKeepTrack(Number320 taskId) |
public void addQueue(FutureRunnable futureRunnable)
public void shutdown()
public void startTracking(TaskRPC taskRPC, ConnectionReservation connectionReservation)
public void startDelayedChannelCreator()
public void startMaintainance(PeerMap peerMap, HandshakeRPC handshakeRPC, ConnectionReservation connectionReservation, int max)
public void startTimeout()
public void scheduleTimeout(BaseFuture baseFuture, int millis, String reason)
public void keepTrack(PeerAddress remotePeer, Number160 taskId, TaskResultListener taskResultListener)
public void stopKeepTrack(Number320 taskId)
public void addConnectionQueue(FutureChannel futureChannelCreation, Semaphore semaphore, Runnable runnable)
public ScheduledExecutorService getScheduledExecutorServiceMaintenance()
public ScheduledExecutorService getScheduledExecutorServiceReplication()
Copyright © 2013. All Rights Reserved.