Package me.ahoo.cosid.segment.concurrent

Class PrefetchWorkerExecutorService

java.lang.Object

me.ahoo.cosid.segment.concurrent.PrefetchWorkerExecutorService

public class PrefetchWorkerExecutorService
extends Object

Prefetch Worker Executor Service.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	PrefetchWorkerExecutorService.GracefullyCloser

Field Summary

Fields

Modifier and Type	Field	Description
static final Duration	DEFAULT_PREFETCH_PERIOD

Constructor Summary

Constructors

Constructor	Description
PrefetchWorkerExecutorService(Duration prefetchPeriod, int corePoolSize)
PrefetchWorkerExecutorService(Duration prefetchPeriod, int corePoolSize, boolean shutdownHook)

Method Summary

Modifier and Type	Method	Description
static PrefetchWorkerExecutorService	shared()	The executor shared by segment chains that are not given one, created on first use.
void	shutdown()
void	submit(AffinityJob affinityJob)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_PREFETCH_PERIOD

public static final Duration DEFAULT_PREFETCH_PERIOD

Constructor Details

PrefetchWorkerExecutorService

public PrefetchWorkerExecutorService(Duration prefetchPeriod,
 int corePoolSize)

PrefetchWorkerExecutorService

public PrefetchWorkerExecutorService(Duration prefetchPeriod,
 int corePoolSize,
 boolean shutdownHook)

Method Details

shared

public static PrefetchWorkerExecutorService shared()

The executor shared by segment chains that are not given one, created on first use.

It has one worker per available processor and shuts down with the JVM. Applications that manage their own lifecycle, like the Spring Boot starter, should pass their own executor instead.

Returns:

the shared executor

shutdown

public void shutdown()

submit

public void submit(AffinityJob affinityJob)