Package io.objectbox.internal

Class ObjectBoxThreadPool

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

io.objectbox.internal.ObjectBoxThreadPool

All Implemented Interfaces:

AutoCloseable, Executor, ExecutorService

@Internal
public class ObjectBoxThreadPool
extends ThreadPoolExecutor

Custom thread pool similar to Executors.newCachedThreadPool() with the following adjustments:

• Release thread local resources (BoxStore.closeThreadResources())
• Reduce keep-alive time for threads to 20 seconds
• Uses a ThreadFactory to name threads like "ObjectBox-1-Thread-1"

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	ObjectBoxThreadPool.ObjectBoxThreadFactory

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Field Summary

Fields

Modifier and Type	Field	Description
private final BoxStore	boxStore

Constructor Summary

Constructors

Constructor	Description
ObjectBoxThreadPool(BoxStore boxStore)

Method Summary

Modifier and Type	Method	Description
protected void	afterExecute(Runnable runnable, Throwable throwable)

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, execute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, terminated, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.ExecutorService

close

Field Details

boxStore

private final BoxStore boxStore

Constructor Details

ObjectBoxThreadPool

public ObjectBoxThreadPool(BoxStore boxStore)

Method Details

afterExecute

protected void afterExecute(Runnable runnable,
 Throwable throwable)

Overrides:

afterExecute in class ThreadPoolExecutor