pl.edu.agh.age.services.worker.internal

Class DefaultThreadPool

java.lang.Object

pl.edu.agh.age.services.worker.internal.DefaultThreadPool

All Implemented Interfaces:

ThreadPool

public final class DefaultThreadPool
extends java.lang.Object
implements ThreadPool

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	logger
private ListeningScheduledExecutorService	service

Constructor Summary

Constructors

Constructor and Description
DefaultThreadPool()

Method Summary

Modifier and Type	Method and Description
ListenableScheduledFuture<?>	scheduleAtFixedRate(java.lang.Runnable command, long initialDelay, long period, java.util.concurrent.TimeUnit unit)
void	shutdownAll()
java.util.List<ListenableFuture<?>>	submitAll(java.util.List<? extends java.lang.Runnable> runnables)

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final org.slf4j.Logger logger

service

private final ListeningScheduledExecutorService service

Constructor Detail

DefaultThreadPool

public DefaultThreadPool()

Method Detail

submitAll

public java.util.List<ListenableFuture<?>> submitAll(java.util.List<? extends java.lang.Runnable> runnables)

Specified by:

submitAll in interface ThreadPool

scheduleAtFixedRate

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

Specified by:

scheduleAtFixedRate in interface ThreadPool

shutdownAll

public void shutdownAll()