Package com.bumptech.glide.load.engine.executor

Class GlideExecutor

java.lang.Object

com.bumptech.glide.load.engine.executor.GlideExecutor

All Implemented Interfaces:

Executor, ExecutorService

public final class GlideExecutor
extends Object
implements ExecutorService

A prioritized ThreadPoolExecutor for running jobs in Glide.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	GlideExecutor.Builder	A builder for GlideExecutors.
static interface	GlideExecutor.UncaughtThrowableStrategy	A strategy for handling unexpected and uncaught Throwables thrown by futures run on the pool.

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long timeout, TimeUnit unit)
static int	calculateBestThreadCount()	Determines the number of cores available on the device.
void	execute(Runnable command)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
<T> T	invokeAny(Collection<? extends Callable<T>> tasks)
<T> T	invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
boolean	isShutdown()
boolean	isTerminated()
static GlideExecutor.Builder	newAnimationBuilder()	Returns a new fixed thread pool that defaults to either one or two threads depending on the number of available cores to use when loading frames of animations.
static GlideExecutor	newAnimationExecutor()	Shortcut for calling GlideExecutor.Builder.build() on newAnimationBuilder().
static GlideExecutor	newAnimationExecutor(int threadCount, GlideExecutor.UncaughtThrowableStrategy uncaughtThrowableStrategy)	Deprecated. Use newAnimationBuilder() instead.
static GlideExecutor.Builder	newDiskCacheBuilder()	Returns a new GlideExecutor.Builder with the DEFAULT_DISK_CACHE_EXECUTOR_THREADS threads, DEFAULT_DISK_CACHE_EXECUTOR_NAME name and GlideExecutor.UncaughtThrowableStrategy.DEFAULT uncaught throwable strategy.
static GlideExecutor	newDiskCacheExecutor()	Shortcut for calling GlideExecutor.Builder.build() on newDiskCacheBuilder().
static GlideExecutor	newDiskCacheExecutor(int threadCount, String name, GlideExecutor.UncaughtThrowableStrategy uncaughtThrowableStrategy)	Deprecated. Use newDiskCacheBuilder() instead.
static GlideExecutor	newDiskCacheExecutor(GlideExecutor.UncaughtThrowableStrategy uncaughtThrowableStrategy)	Deprecated. Use newDiskCacheBuilder() and GlideExecutor.Builder.setUncaughtThrowableStrategy(UncaughtThrowableStrategy) instead.
static GlideExecutor.Builder	newSourceBuilder()	Returns a new GlideExecutor.Builder with the default thread count returned from calculateBestThreadCount(), the DEFAULT_SOURCE_EXECUTOR_NAME thread name prefix, and the GlideExecutor.UncaughtThrowableStrategy.DEFAULT uncaught throwable strategy.
static GlideExecutor	newSourceExecutor()	Shortcut for calling GlideExecutor.Builder.build() on newSourceBuilder().
static GlideExecutor	newSourceExecutor(int threadCount, String name, GlideExecutor.UncaughtThrowableStrategy uncaughtThrowableStrategy)	Deprecated. Use newSourceBuilder() instead.
static GlideExecutor	newSourceExecutor(GlideExecutor.UncaughtThrowableStrategy uncaughtThrowableStrategy)	Deprecated. Use newSourceBuilder() instead.
static GlideExecutor	newUnlimitedSourceExecutor()	Returns a new unlimited thread pool with zero core thread count to make sure no threads are created by default, KEEP_ALIVE_TIME_MS keep alive time, the DEFAULT_SOURCE_UNLIMITED_EXECUTOR_NAME thread name prefix, the GlideExecutor.UncaughtThrowableStrategy.DEFAULT uncaught throwable strategy, and the SynchronousQueue since using default unbounded blocking queue, for example, PriorityBlockingQueue effectively won't create more than corePoolSize threads.
void	shutdown()
List<Runnable>	shutdownNow()
Future<?>	submit(Runnable task)
<T> Future<T>	submit(Runnable task, T result)
<T> Future<T>	submit(Callable<T> task)
String	toString()

Methods inherited from class java.lang.Object

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

Method Details

newDiskCacheBuilder

public static GlideExecutor.Builder newDiskCacheBuilder()

Returns a new GlideExecutor.Builder with the DEFAULT_DISK_CACHE_EXECUTOR_THREADS threads, DEFAULT_DISK_CACHE_EXECUTOR_NAME name and GlideExecutor.UncaughtThrowableStrategy.DEFAULT uncaught throwable strategy.

Disk cache executors do not allow network operations on their threads.

newDiskCacheExecutor

public static GlideExecutor newDiskCacheExecutor()

Shortcut for calling GlideExecutor.Builder.build() on newDiskCacheBuilder().

newDiskCacheExecutor

@Deprecated
public static GlideExecutor newDiskCacheExecutor(GlideExecutor.UncaughtThrowableStrategy uncaughtThrowableStrategy)

Deprecated.

Use newDiskCacheBuilder() and GlideExecutor.Builder.setUncaughtThrowableStrategy(UncaughtThrowableStrategy) instead.

newDiskCacheExecutor

@Deprecated
public static GlideExecutor newDiskCacheExecutor(int threadCount,
 String name,
 GlideExecutor.UncaughtThrowableStrategy uncaughtThrowableStrategy)

Deprecated.

Use newDiskCacheBuilder() instead.

newSourceBuilder

public static GlideExecutor.Builder newSourceBuilder()

Returns a new GlideExecutor.Builder with the default thread count returned from calculateBestThreadCount(), the DEFAULT_SOURCE_EXECUTOR_NAME thread name prefix, and the GlideExecutor.UncaughtThrowableStrategy.DEFAULT uncaught throwable strategy.

Source executors allow network operations on their threads.

newSourceExecutor

public static GlideExecutor newSourceExecutor()

Shortcut for calling GlideExecutor.Builder.build() on newSourceBuilder().

newSourceExecutor

@Deprecated
public static GlideExecutor newSourceExecutor(GlideExecutor.UncaughtThrowableStrategy uncaughtThrowableStrategy)

Deprecated.

Use newSourceBuilder() instead.

newSourceExecutor

@Deprecated
public static GlideExecutor newSourceExecutor(int threadCount,
 String name,
 GlideExecutor.UncaughtThrowableStrategy uncaughtThrowableStrategy)

Deprecated.

Use newSourceBuilder() instead.

newUnlimitedSourceExecutor

public static GlideExecutor newUnlimitedSourceExecutor()

Returns a new unlimited thread pool with zero core thread count to make sure no threads are created by default, KEEP_ALIVE_TIME_MS keep alive time, the DEFAULT_SOURCE_UNLIMITED_EXECUTOR_NAME thread name prefix, the GlideExecutor.UncaughtThrowableStrategy.DEFAULT uncaught throwable strategy, and the SynchronousQueue since using default unbounded blocking queue, for example, PriorityBlockingQueue effectively won't create more than corePoolSize threads. See ThreadPoolExecutor documentation.

Source executors allow network operations on their threads.

newAnimationBuilder

public static GlideExecutor.Builder newAnimationBuilder()

Returns a new fixed thread pool that defaults to either one or two threads depending on the number of available cores to use when loading frames of animations.

Animation executors do not allow network operations on their threads.

newAnimationExecutor

public static GlideExecutor newAnimationExecutor()

Shortcut for calling GlideExecutor.Builder.build() on newAnimationBuilder().

newAnimationExecutor

@Deprecated
public static GlideExecutor newAnimationExecutor(int threadCount,
 GlideExecutor.UncaughtThrowableStrategy uncaughtThrowableStrategy)

Deprecated.

Use newAnimationBuilder() instead.

execute

public void execute(@NonNull
 Runnable command)

Specified by:

execute in interface Executor

submit

@NonNull
public Future<?> submit(@NonNull
 Runnable task)

Specified by:

submit in interface ExecutorService

invokeAll

@NonNull
public <T> List<Future<T>> invokeAll(@NonNull
 Collection<? extends Callable<T>> tasks)
                              throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAll

@NonNull
public <T> List<Future<T>> invokeAll(@NonNull
 Collection<? extends Callable<T>> tasks,
 long timeout,
 @NonNull
 TimeUnit unit)
                              throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAny

@NonNull
public <T> T invokeAny(@NonNull
 Collection<? extends Callable<T>> tasks)
                throws InterruptedException,
ExecutionException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

invokeAny

public <T> T invokeAny(@NonNull
 Collection<? extends Callable<T>> tasks,
 long timeout,
 @NonNull
 TimeUnit unit)
                throws InterruptedException,
ExecutionException,
TimeoutException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

TimeoutException

submit

@NonNull
public <T> Future<T> submit(@NonNull
 Runnable task,
 T result)

Specified by:

submit in interface ExecutorService

submit

public <T> Future<T> submit(@NonNull
 Callable<T> task)

Specified by:

submit in interface ExecutorService

shutdown

public void shutdown()

Specified by:

shutdown in interface ExecutorService

shutdownNow

@NonNull
public List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface ExecutorService

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface ExecutorService

awaitTermination

public boolean awaitTermination(long timeout,
 @NonNull
 TimeUnit unit)
                         throws InterruptedException

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

toString

public String toString()

Overrides:

toString in class Object

calculateBestThreadCount

public static int calculateBestThreadCount()

Determines the number of cores available on the device.