Package jadx.core.utils.tasks

Class TaskExecutor

java.lang.Object

jadx.core.utils.tasks.TaskExecutor

All Implemented Interfaces:

ITaskExecutor

public class TaskExecutor
extends Object
implements ITaskExecutor

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	TaskExecutor.ExecStage
private static enum	TaskExecutor.ExecType

Field Summary

Fields

Modifier and Type	Field	Description
private @Nullable ExecutorService	executor
private final Object	executorSync
private static final org.slf4j.Logger	LOG
private final AtomicInteger	progress
private final AtomicBoolean	running
private final List<TaskExecutor.ExecStage>	stages
private int	tasksCount
private @Nullable Error	terminateError
private final AtomicBoolean	terminating
private final AtomicInteger	threadsCount

Constructor Summary

Constructors

Constructor	Description
TaskExecutor()

Method Summary

Modifier and Type	Method	Description
void	addParallelTasks(List<? extends Runnable> parallelTasks)	Add parallel stage with provided tasks
void	addSequentialTask(Runnable seqTask)	Add sequential stage with a single task
void	addSequentialTasks(List<? extends Runnable> seqTasks)	Add sequential stage with provided tasks
static void	awaitExecutorTermination(ExecutorService executor)
void	awaitTermination()	Block until execution is finished
void	execute()	Start tasks execution.
@Nullable ExecutorService	getInternalExecutor()	Return internal executor service.
int	getProgress()
int	getTasksCount()	Scheduled tasks count
int	getThreadsCount()
boolean	isRunning()
boolean	isTerminating()
private void	runStages()
void	setThreadsCount(int count)	Set threads count for parallel stage.
private void	stopExecution()
void	terminate()	Not started tasks will be not executed after this method invocation.
private void	terminateWithError(Error error)
private void	wrapTask(Runnable task)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

stages

private final List<TaskExecutor.ExecStage> stages

threadsCount

private final AtomicInteger threadsCount

progress

private final AtomicInteger progress

running

private final AtomicBoolean running

terminating

private final AtomicBoolean terminating

executorSync

private final Object executorSync

executor

@Nullable
private @Nullable ExecutorService executor

tasksCount

private int tasksCount

terminateError

@Nullable
private @Nullable Error terminateError

Constructor Details

TaskExecutor

public TaskExecutor()

Method Details

addParallelTasks

public void addParallelTasks(List<? extends Runnable> parallelTasks)

Description copied from interface: ITaskExecutor

Add parallel stage with provided tasks

Specified by:

addParallelTasks in interface ITaskExecutor

addSequentialTasks

public void addSequentialTasks(List<? extends Runnable> seqTasks)

Description copied from interface: ITaskExecutor

Add sequential stage with provided tasks

Specified by:

addSequentialTasks in interface ITaskExecutor

addSequentialTask

public void addSequentialTask(Runnable seqTask)

Description copied from interface: ITaskExecutor

Add sequential stage with a single task

Specified by:

addSequentialTask in interface ITaskExecutor

getThreadsCount

public int getThreadsCount()

Specified by:

getThreadsCount in interface ITaskExecutor

setThreadsCount

public void setThreadsCount(int count)

Description copied from interface: ITaskExecutor

Set threads count for parallel stage. Can be changed during execution. Defaults to half of processors count.

Specified by:

setThreadsCount in interface ITaskExecutor

getTasksCount

public int getTasksCount()

Description copied from interface: ITaskExecutor

Scheduled tasks count

Specified by:

getTasksCount in interface ITaskExecutor

getProgress

public int getProgress()

Specified by:

getProgress in interface ITaskExecutor

execute

public void execute()

Description copied from interface: ITaskExecutor

Start tasks execution.

Specified by:

execute in interface ITaskExecutor

stopExecution

private void stopExecution()

awaitTermination

public void awaitTermination()

Description copied from interface: ITaskExecutor

Block until execution is finished

Specified by:

awaitTermination in interface ITaskExecutor

terminate

public void terminate()

Description copied from interface: ITaskExecutor

Not started tasks will be not executed after this method invocation.

Specified by:

terminate in interface ITaskExecutor

terminateWithError

private void terminateWithError(Error error)

isTerminating

public boolean isTerminating()

Specified by:

isTerminating in interface ITaskExecutor

isRunning

public boolean isRunning()

Specified by:

isRunning in interface ITaskExecutor

getInternalExecutor

@Nullable
public @Nullable ExecutorService getInternalExecutor()

Description copied from interface: ITaskExecutor

Return internal executor service.

Specified by:

getInternalExecutor in interface ITaskExecutor

runStages

private void runStages()

wrapTask

private void wrapTask(Runnable task)

awaitExecutorTermination

public static void awaitExecutorTermination(ExecutorService executor)