com.helger.photon.app

Class PhotonWorkerPool

java.lang.Object

com.helger.scope.singleton.AbstractSingleton

com.helger.scope.singleton.AbstractGlobalSingleton

com.helger.photon.app.PhotonWorkerPool

All Implemented Interfaces:

com.helger.scope.IScopeDestructionAware

public class PhotonWorkerPool
extends com.helger.scope.singleton.AbstractGlobalSingleton

Asynchronous worker pool that handles stuff that runs in the background.

Since:

8.2.6

Author:

Philip Helger

Field Summary

Fields inherited from class com.helger.scope.singleton.AbstractSingleton

m_aRWLock

Constructor Summary

Constructors

Constructor and Description
PhotonWorkerPool() Deprecated.
PhotonWorkerPool(ExecutorService aES)
PhotonWorkerPool(int nThreadPoolSize)

Method Summary

Modifier and Type	Method and Description
static PhotonWorkerPool	getInstance()
protected void	onDestroy(com.helger.scope.IScope aScopeInDestruction)
CompletableFuture<Void>	run(String sActionName, Runnable aRunnable)
CompletableFuture<Void>	runThrowing(String sActionName, com.helger.commons.callback.IThrowingRunnable<? extends Exception> aRunnable)
<T> CompletableFuture<T>	supply(String sActionName, Supplier<T> aSupplier)
<T> CompletableFuture<T>	supplyThrowing(String sActionName, com.helger.commons.functional.IThrowingSupplier<T,? extends Exception> aSupplier)

Methods inherited from class com.helger.scope.singleton.AbstractGlobalSingleton

getAllGlobalSingletons, getGlobalSingleton, getGlobalSingletonIfInstantiated, isGlobalSingletonInstantiated

Methods inherited from class com.helger.scope.singleton.AbstractSingleton

getAllSingletons, getSingleton, getSingletonIfInstantiated, getSingletonScopeKey, isDestroyed, isInDestruction, isInInstantiation, isInPreDestruction, isInstantiated, isSingletonInstantiated, isUsableObject, onAfterInstantiation, onBeforeDestroy, onBeforeScopeDestruction, onScopeDestruction, readAbstractSingletonFields, setDestroyed, setInDestruction, setInInstantiation, setInPreDestruction, setInstantiated, toString, writeAbstractSingletonFields

Methods inherited from class java.lang.Object

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

Constructor Detail

PhotonWorkerPool

@Deprecated
 @UsedViaReflection
public PhotonWorkerPool()

Deprecated.

PhotonWorkerPool

public PhotonWorkerPool(@Nonnegative
                        int nThreadPoolSize)

PhotonWorkerPool

public PhotonWorkerPool(@Nonnull
                        ExecutorService aES)

Method Detail

getInstance

@Nonnull
public static PhotonWorkerPool getInstance()

onDestroy

protected void onDestroy(@Nonnull
                         com.helger.scope.IScope aScopeInDestruction)
                  throws Exception

Overrides:

onDestroy in class com.helger.scope.singleton.AbstractSingleton

Throws:

Exception

run

@Nonnull
public CompletableFuture<Void> run(@Nonnull
                                             String sActionName,
                                             @Nonnull
                                             Runnable aRunnable)

runThrowing

@Nonnull
public CompletableFuture<Void> runThrowing(@Nonnull
                                                     String sActionName,
                                                     @Nonnull
                                                     com.helger.commons.callback.IThrowingRunnable<? extends Exception> aRunnable)

supply

@Nonnull
public <T> CompletableFuture<T> supply(@Nonnull
                                                 String sActionName,
                                                 @Nonnull
                                                 Supplier<T> aSupplier)

supplyThrowing

@Nonnull
public <T> CompletableFuture<T> supplyThrowing(@Nonnull
                                                         String sActionName,
                                                         @Nonnull
                                                         com.helger.commons.functional.IThrowingSupplier<T,? extends Exception> aSupplier)