helix.graph.util
Class ConcurrentService

java.lang.Object
  extended by helix.graph.util.ConcurrentService

public class ConcurrentService
extends Object


Constructor Summary
ConcurrentService()
           
ConcurrentService(int poolSize)
           
 
Method Summary
 void addProcess(Iterable<Runnable> processes)
           
 void addProcess(Runnable process)
           
static int getAvailableProcessors()
           
 int getNbRunningProcesses()
           
 int getPoolSize()
           
 boolean isEnabled()
           
 void lock()
           
 void shutdown()
           
 void unlock()
           
 void waitCompletion()
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ConcurrentService

public ConcurrentService(int poolSize)

ConcurrentService

public ConcurrentService()
Method Detail

getAvailableProcessors

public static int getAvailableProcessors()

isEnabled

public boolean isEnabled()

getPoolSize

public int getPoolSize()

getNbRunningProcesses

public int getNbRunningProcesses()

addProcess

public void addProcess(Runnable process)

addProcess

public void addProcess(Iterable<Runnable> processes)

lock

public void lock()

unlock

public void unlock()

waitCompletion

public void waitCompletion()

shutdown

public void shutdown()