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 PrefetchWorkerExecutorService	DEFAULT
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
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

DEFAULT

public static final PrefetchWorkerExecutorService DEFAULT

Constructor Details

PrefetchWorkerExecutorService

public PrefetchWorkerExecutorService(Duration prefetchPeriod,
 int corePoolSize)

PrefetchWorkerExecutorService

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

Method Details

shutdown

public void shutdown()

submit

public void submit(AffinityJob affinityJob)