me.ahoo.cosid.segment.concurrent

Class PrefetchWorkerExecutorService

java.lang.Object

me.ahoo.cosid.segment.concurrent.PrefetchWorkerExecutorService

public class PrefetchWorkerExecutorService
extends java.lang.Object

Prefetch Worker Executor Service.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	PrefetchWorkerExecutorService.GracefullyCloser

Field Summary

Fields

Modifier and Type	Field and Description
static PrefetchWorkerExecutorService	DEFAULT
static java.time.Duration	DEFAULT_PREFETCH_PERIOD

Constructor Summary

Constructors

Constructor and Description
PrefetchWorkerExecutorService(java.time.Duration prefetchPeriod, int corePoolSize)
PrefetchWorkerExecutorService(java.time.Duration prefetchPeriod, int corePoolSize, boolean shutdownHook)

Method Summary

Modifier and Type	Method and Description
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 Detail

DEFAULT_PREFETCH_PERIOD

public static final java.time.Duration DEFAULT_PREFETCH_PERIOD

DEFAULT

public static final PrefetchWorkerExecutorService DEFAULT

Constructor Detail

PrefetchWorkerExecutorService

public PrefetchWorkerExecutorService(java.time.Duration prefetchPeriod,
                                     int corePoolSize)

PrefetchWorkerExecutorService

public PrefetchWorkerExecutorService(java.time.Duration prefetchPeriod,
                                     int corePoolSize,
                                     boolean shutdownHook)

Method Detail

shutdown

public void shutdown()

submit

public void submit(AffinityJob affinityJob)