IdlingScheduledThreadPoolExecutor

Artifact: androidx.test.espresso.idling:idling-concurrent

Kotlin |Java

class IdlingScheduledThreadPoolExecutor : ScheduledThreadPoolExecutor, IdlingResource

kotlin.Any
↳	java.util.concurrent.AbstractExecutorService
	↳	java.util.concurrent.ThreadPoolExecutor
		↳	java.util.concurrent.ScheduledThreadPoolExecutor
			↳	androidx.test.espresso.idling.concurrent.IdlingScheduledThreadPoolExecutor

A ScheduledThreadPoolExecutor that can be registered as an IdlingResource with Espresso.

Overrides parent methods to monitor threads starting, and finishing execution. Uses to track number of active tasks.

Summary

Public constructors
`IdlingScheduledThreadPoolExecutor( resourceName: String!, corePoolSize: Int, threadFactory: ThreadFactory! )` Creates a new `IdlingScheduledThreadPoolExecutor` with the given initial parameters.
`IdlingScheduledThreadPoolExecutor( resourceName: String!, corePoolSize: Int, threadFactory: ThreadFactory!, debugCounting: Boolean )` Creates a new `IdlingScheduledThreadPoolExecutor` with the given initial parameters.

Public functions
`String!`	`getName()` Returns the name of the resources (used for logging and idempotency of registration).
`Boolean`	`isIdleNow()` Returns `true` if resource is currently idle.
`Unit`	`registerIdleTransitionCallback( callback: IdlingResource.ResourceCallback! )` Registers the given `ResourceCallback` with the resource.
`ScheduledFuture<V!>!`	`<V> schedule(callable: Callable<V!>!, delay: Long, unit: TimeUnit!)`
`ScheduledFuture<Any!>!`	`schedule(command: Runnable!, delay: Long, unit: TimeUnit!)`

Protected functions
`Unit`	`afterExecute(r: Runnable!, t: Throwable!)`
`Unit`	`beforeExecute(t: Thread!, r: Runnable!)`
`Unit`	`terminated()`

Inherited functions

From java.util.concurrent.AbstractExecutorService

`(Mutable)List<Future<T!>!>!`	`<T> invokeAll(tasks: (Mutable)Collection<Callable<T!>!>!)`
`T!`	`<T> invokeAny(tasks: (Mutable)Collection<Callable<T!>!>!)`
`RunnableFuture<T!>!`	`<T> newTaskFor(runnable: Runnable!, value: T!)`

From java.util.concurrent.ScheduledThreadPoolExecutor

`RunnableScheduledFuture<V!>!`	`<V> decorateTask(runnable: Runnable!, task: RunnableScheduledFuture<V!>!)`
`Unit`	`execute(command: Runnable!)`
`Boolean`	`getContinueExistingPeriodicTasksAfterShutdownPolicy()`
`Boolean`	`getExecuteExistingDelayedTasksAfterShutdownPolicy()`
`BlockingQueue<Runnable!>!`	`getQueue()`
`Boolean`	`getRemoveOnCancelPolicy()`
`ScheduledFuture<Any!>!`	`scheduleAtFixedRate( command: Runnable!, initialDelay: Long, period: Long, unit: TimeUnit! )`
`ScheduledFuture<Any!>!`	`scheduleWithFixedDelay( command: Runnable!, initialDelay: Long, delay: Long, unit: TimeUnit! )`
`Unit`	`setContinueExistingPeriodicTasksAfterShutdownPolicy(value: Boolean)`
`Unit`	`setExecuteExistingDelayedTasksAfterShutdownPolicy(value: Boolean)`
`Unit`	`setRemoveOnCancelPolicy(value: Boolean)`
`Unit`	`shutdown()`
`(Mutable)List<Runnable!>!`	`shutdownNow()`
`Future<Any!>!`	`submit(task: Runnable!)`
`Future<T!>!`	`<T> submit(task: Runnable!, result: T!)`

From java.util.concurrent.ThreadPoolExecutor

`Unit`	`allowCoreThreadTimeOut(value: Boolean)`
`Boolean`	`allowsCoreThreadTimeOut()`
`Boolean`	`awaitTermination(timeout: Long, unit: TimeUnit!)`
`Unit`	`finalize()` This function is deprecated.
`Int`	`getActiveCount()`
`Long`	`getCompletedTaskCount()`
`Int`	`getCorePoolSize()`
`Long`	`getKeepAliveTime(unit: TimeUnit!)`
`Int`	`getLargestPoolSize()`
`Int`	`getMaximumPoolSize()`
`Int`	`getPoolSize()`
`RejectedExecutionHandler!`	`getRejectedExecutionHandler()`
`Long`	`getTaskCount()`
`ThreadFactory!`	`getThreadFactory()`
`Boolean`	`isShutdown()`
`Boolean`	`isTerminated()`
`Boolean`	`isTerminating()`
`Int`	`prestartAllCoreThreads()`
`Boolean`	`prestartCoreThread()`
`Unit`	`purge()`
`Boolean`	`remove(task: Runnable!)`
`Unit`	`setCorePoolSize(corePoolSize: Int)`
`Unit`	`setKeepAliveTime(time: Long, unit: TimeUnit!)`
`Unit`	`setMaximumPoolSize(maximumPoolSize: Int)`
`Unit`	`setRejectedExecutionHandler(handler: RejectedExecutionHandler!)`
`Unit`	`setThreadFactory(threadFactory: ThreadFactory!)`
`String!`	`toString()`

Public constructors

IdlingScheduledThreadPoolExecutor

IdlingScheduledThreadPoolExecutor(
    resourceName: String!,
    corePoolSize: Int,
    threadFactory: ThreadFactory!
)

Creates a new IdlingScheduledThreadPoolExecutor with the given initial parameters.

Parameters
`resourceName: String!`	the name of the executor (used for logging and idempotency of registration).
`corePoolSize: Int`	the number of threads to keep in the pool, even if they are idle, unless allowCoreThreadTimeOut is set.
`threadFactory: ThreadFactory!`	the factory to use when the executor creates a new thread.

IdlingScheduledThreadPoolExecutor

IdlingScheduledThreadPoolExecutor(
    resourceName: String!,
    corePoolSize: Int,
    threadFactory: ThreadFactory!,
    debugCounting: Boolean
)

Creates a new IdlingScheduledThreadPoolExecutor with the given initial parameters.

Parameters
`resourceName: String!`	the name of the executor (used for logging and idempotency of registration).
`corePoolSize: Int`	the number of threads to keep in the pool, even if they are idle, unless allowCoreThreadTimeOut is set.
`threadFactory: ThreadFactory!`	the factory to use when the executor creates a new thread.
`debugCounting: Boolean`	if true increment &decrement calls will print trace information to logs.

Public functions

getName

fun getName(): String!

Returns the name of the resources (used for logging and idempotency of registration).

isIdleNow

fun isIdleNow(): Boolean

Returns true if resource is currently idle. Espresso will always call this method from the main thread, therefore it should be non-blocking and return immediately.

registerIdleTransitionCallback

fun registerIdleTransitionCallback(
    callback: IdlingResource.ResourceCallback!
): Unit

Registers the given ResourceCallback with the resource. Espresso will call this method:

with its implementation of ResourceCallback so it can be notified asynchronously that your resource is idle
from the main thread, but you are free to execute the callback's onTransitionToIdle from any thread
once (when it is initially given a reference to your IdlingResource)

You only need to call this upon transition from busy to idle - if the resource is already idle when the method is called invoking the call back is optional and has no significant impact.

schedule

fun <V> schedule(callable: Callable<V!>!, delay: Long, unit: TimeUnit!): ScheduledFuture<V!>!

schedule

fun schedule(command: Runnable!, delay: Long, unit: TimeUnit!): ScheduledFuture<Any!>!

Protected functions

afterExecute

protected fun afterExecute(r: Runnable!, t: Throwable!): Unit

beforeExecute

protected fun beforeExecute(t: Thread!, r: Runnable!): Unit

terminated

protected fun terminated(): Unit