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

Class GlideExecutor

java.lang.Object

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

All Implemented Interfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService

public final class GlideExecutor
extends java.lang.Object
implements java.util.concurrent.ExecutorService

A prioritized ThreadPoolExecutor for running jobs in Glide.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static 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, java.util.concurrent.TimeUnit unit)
static int	calculateBestThreadCount()	Determines the number of cores available on the device.
void	execute(java.lang.Runnable command)
<T> java.util.List<java.util.concurrent.Future<T>>	invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
<T> java.util.List<java.util.concurrent.Future<T>>	invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, long timeout, java.util.concurrent.TimeUnit unit)
<T> T	invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
<T> T	invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, long timeout, java.util.concurrent.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, java.lang.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, java.lang.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()
java.util.List<java.lang.Runnable>	shutdownNow()
java.util.concurrent.Future<?>	submit(java.lang.Runnable task)
<T> java.util.concurrent.Future<T>	submit(java.lang.Runnable task, T result)
<T> java.util.concurrent.Future<T>	submit(java.util.concurrent.Callable<T> task)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

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,
                                                 java.lang.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,
                                              java.lang.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
                    java.lang.Runnable command)

Specified by:

execute in interface java.util.concurrent.Executor

submit

@NonNull
public java.util.concurrent.Future<?> submit(@NonNull
                                             java.lang.Runnable task)

Specified by:

submit in interface java.util.concurrent.ExecutorService

invokeAll

@NonNull
public <T> java.util.List<java.util.concurrent.Future<T>> invokeAll(@NonNull
                                                                    java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
                                                             throws java.lang.InterruptedException

Specified by:

invokeAll in interface java.util.concurrent.ExecutorService

Throws:

java.lang.InterruptedException

invokeAll

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

Specified by:

invokeAll in interface java.util.concurrent.ExecutorService

Throws:

java.lang.InterruptedException

invokeAny

@NonNull
public <T> T invokeAny(@NonNull
                       java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
                throws java.lang.InterruptedException,
                       java.util.concurrent.ExecutionException

Specified by:

invokeAny in interface java.util.concurrent.ExecutorService

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

invokeAny

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

Specified by:

invokeAny in interface java.util.concurrent.ExecutorService

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

submit

@NonNull
public <T> java.util.concurrent.Future<T> submit(@NonNull
                                                 java.lang.Runnable task,
                                                 T result)

Specified by:

submit in interface java.util.concurrent.ExecutorService

submit

public <T> java.util.concurrent.Future<T> submit(@NonNull
                                                 java.util.concurrent.Callable<T> task)

Specified by:

submit in interface java.util.concurrent.ExecutorService

shutdown

public void shutdown()

Specified by:

shutdown in interface java.util.concurrent.ExecutorService

shutdownNow

@NonNull
public java.util.List<java.lang.Runnable> shutdownNow()

Specified by:

shutdownNow in interface java.util.concurrent.ExecutorService

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface java.util.concurrent.ExecutorService

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface java.util.concurrent.ExecutorService

awaitTermination

public boolean awaitTermination(long timeout,
                                @NonNull
                                java.util.concurrent.TimeUnit unit)
                         throws java.lang.InterruptedException

Specified by:

awaitTermination in interface java.util.concurrent.ExecutorService

Throws:

java.lang.InterruptedException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

calculateBestThreadCount

public static int calculateBestThreadCount()

Determines the number of cores available on the device.