```
public class TaskQueue

                    
```
Manages priority- and dependency-driven execution of background tasks.
The queue rejects re-adding tasks that are already scheduled or running — two tasks are considered equal if they are the same object, or share both TaskType and id. Subclasses control duplication semantics through the appropriate Task constructor; see com.appsflyer.internal.components.queue.tasks.UpdateRemoteControlTask for an example.
Heavy resources (queue ThreadPoolExecutor, service executor, Timer, skip-lists) are created lazily on first use so constructing the queue / registering listeners on the main thread does not allocate threads or trigger Cleaner registration.

Constructor Summary

Constructors
Constructor	Description
`TaskQueue(ExecutorService mainExecutor)`	Convenience for tests and call sites that already hold an ExecutorService.
`TaskQueue(DependencyProvider<ExecutorService> mainExecutorProvider)`

Method Summary

Modifier and Type	Method	Description
`Unit`	`addTask(Task<?> task)`
`Unit`	`registerListener(QueueStatusListener listener)`
`Unit`	`unRegisterListener(QueueStatusListener listener)`
`Unit`	`setServiceExecutor(Executor serviceExecutor)`	Used by unit tests to force all reordering / add / drop operations onto a synchronous executor.
`Boolean`	`shouldRetryInSession(Task<?> task)`	Whether task should be retried within the current session.
`List<Task<?>>`	`getAllPendingTasks()`	Returns the tasks that will be run in the future (currently pending + failed-to-retry), sorted in the same order they're held in the queue.
`List<Task<?>>`	`getBlockedTasksCollection()`
`Set<Task<?>>`	`getRunningTasksCollection()`
`Unit`	`clearAll()`	Removes every task from every internal collection.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - TaskQueue
```
TaskQueue(ExecutorService mainExecutor)
```
    Convenience for tests and call sites that already hold an ExecutorService.
  - TaskQueue
```
TaskQueue(DependencyProvider<ExecutorService> mainExecutorProvider)
```
- Method Detail
  - addTask
```
 Unit addTask(Task<?> task)
```
  - registerListener
```
 Unit registerListener(QueueStatusListener listener)
```
  - unRegisterListener
```
 Unit unRegisterListener(QueueStatusListener listener)
```
  - setServiceExecutor
```
 Unit setServiceExecutor(Executor serviceExecutor)
```
    Used by unit tests to force all reordering / add / drop operations onto a synchronous executor.
  - shouldRetryInSession
```
 Boolean shouldRetryInSession(Task<?> task)
```
    Whether task should be retried within the current session.
    To prevent an infinite retry loop of cached ARS requests, those are retried at most once per session (the retry is only meaningful when the server is missing credentials).
  - getAllPendingTasks
```
 List<Task<?>> getAllPendingTasks()
```
    Returns the tasks that will be run in the future (currently pending + failed-to-retry), sorted in the same order they're held in the queue.
  - getBlockedTasksCollection
```
 List<Task<?>> getBlockedTasksCollection()
```
  - getRunningTasksCollection
```
 Set<Task<?>> getRunningTasksCollection()
```
  - clearAll
```
 Unit clearAll()
```
    Removes every task from every internal collection. Running tasks are not interrupted. Debug / test utility only.

Class TaskQueue

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

TaskQueue

TaskQueue

Method Detail

addTask

registerListener

unRegisterListener

setServiceExecutor

shouldRetryInSession

getAllPendingTasks

getBlockedTasksCollection

getRunningTasksCollection

clearAll