Kompics

public final class Kompics

The Kompics class.

Author:Cosmin Arad <cosmin@sics.se>, Jim Dowling <jdowling@sics.se>, Lars Kroll <lkroll@kth.se>

Fields

SHUTDOWN_TIMEOUT

public static final long SHUTDOWN_TIMEOUT

logger

public static final Logger logger

maxNumOfExecutedEvents

public static final AtomicInteger maxNumOfExecutedEvents

Methods

asyncShutdown

public static void asyncShutdown()

createAndStart

public static <C extends ComponentDefinition> void createAndStart(Class<C> main)

Creates the and start.

Parameters:
  • main – the main

createAndStart

public static <C extends ComponentDefinition> void createAndStart(Class<C> main, Init<C> initEvent)

createAndStart

public static <C extends ComponentDefinition> void createAndStart(Class<C> main, int workers)

Creates the and start.

Parameters:
  • main – the main
  • workers – the workers

createAndStart

public static <C extends ComponentDefinition> void createAndStart(Class<C> main, Init<C> initEvent, int workers)

createAndStart

public static <C extends ComponentDefinition> void createAndStart(Class<C> main, int workers, int maxEventExecuteNumber)

createAndStart

public static <C extends ComponentDefinition> void createAndStart(Class<C> main, Init<C> initEvent, int workers, int maxEventExecuteNumber)

Creates the main component and starts it.

Parameters:
  • <T>
  • main – the main
  • initEvent
  • workers – the workers
  • maxEventExecuteNumber

forceShutdown

public static void forceShutdown()

getConfig

public static Config getConfig()

getFaultHandler

public static FaultHandler getFaultHandler()

getScheduler

public static Scheduler getScheduler()

handleFault

static void handleFault(Fault f)

isOn

public static boolean isOn()

logStats

public static void logStats()

Log stats.

resetConfig

public static void resetConfig()

resetFaultHandler

public static void resetFaultHandler()

setConfig

public static void setConfig(Config conf)

setFaultHandler

public static void setFaultHandler(FaultHandler fh)

setScheduler

public static void setScheduler(Scheduler sched)

shutdown

public static void shutdown()

waitForTermination

public static void waitForTermination()