org.mini2Dx.miniscript.core.threadpool

Class KavaThreadPoolProvider

java.lang.Object

org.mini2Dx.miniscript.core.threadpool.KavaThreadPoolProvider

All Implemented Interfaces:

java.lang.Runnable, ThreadPoolProvider

public class KavaThreadPoolProvider
extends java.lang.Object
implements java.lang.Runnable, ThreadPoolProvider

ThreadPoolProvider implementation for Kava-based runtimes

Constructor Summary

Constructors

Constructor and Description
KavaThreadPoolProvider()
KavaThreadPoolProvider(int maxConcurrentScripts)

Method Summary

Modifier and Type	Method and Description
void	run()
java.util.concurrent.ScheduledFuture<?>	schedule(java.lang.Runnable command, long delay, java.util.concurrent.TimeUnit unit)
java.util.concurrent.ScheduledFuture<?>	scheduleAtFixedRate(java.lang.Runnable command, long initialDelay, long period, java.util.concurrent.TimeUnit unit)
void	shutdown(boolean interruptThreads)
java.util.concurrent.Future<?>	submit(java.lang.Runnable task)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KavaThreadPoolProvider

public KavaThreadPoolProvider()

KavaThreadPoolProvider

public KavaThreadPoolProvider(int maxConcurrentScripts)

Method Detail

submit

public java.util.concurrent.Future<?> submit(java.lang.Runnable task)

Specified by:

submit in interface ThreadPoolProvider

scheduleAtFixedRate

public java.util.concurrent.ScheduledFuture<?> scheduleAtFixedRate(java.lang.Runnable command,
                                                                   long initialDelay,
                                                                   long period,
                                                                   java.util.concurrent.TimeUnit unit)

Specified by:

scheduleAtFixedRate in interface ThreadPoolProvider

schedule

public java.util.concurrent.ScheduledFuture<?> schedule(java.lang.Runnable command,
                                                        long delay,
                                                        java.util.concurrent.TimeUnit unit)

Specified by:

schedule in interface ThreadPoolProvider

shutdown

public void shutdown(boolean interruptThreads)

Specified by:

shutdown in interface ThreadPoolProvider

run

public void run()

Specified by:

run in interface java.lang.Runnable