Modifier and Type	Class and Description
pack-priv class	CarefulRunnableQueue.TaskThread

Modifier and Type	Field and Description
private boolean	gentle_close_requested
private static final MLogger	logger
private boolean	shutdown_on_interrupt
private List<E>	strandedTasks
private CarefulRunnableQueue.TaskThread	t
private List<E>	taskList

Access	Constructor and Description
public	CarefulRunnableQueue(boolean daemon, boolean shutdown_on_interrupt)

Method Summary

Modifier and Type	Method and Description
public RunnableQueue	asRunnableQueue() Implements com.mchange.v2.async.Queuable.asRunnableQueue.
private synchronized void	awaitTask()
public synchronized void	close(boolean Should be regarded as a hint, not a guarantee. If true, pending, not-yet-performed tasks will be skipped, if possible. Currently executing tasks may or may not be interrupted. If false, all previously scheduled tasks will be completed prior to clean-up. The method returns immediately regardless. skip_remaining_tasks) Implements com.mchange.v2.async.AsynchronousRunner.close. Finish with this AsynchronousRunner, and clean-up any Threads or resources it may hold.
public synchronized void	close() Implements com.mchange.v2.async.AsynchronousRunner.close. Clean-up resources held by this asynchronous runner as soon as possible.
private synchronized Runnable	dequeueRunnable()
public synchronized List<E>	getStrandedTasks() Implements com.mchange.v2.async.StrandedTaskReporting.getStrandedTasks. makes available any tasks that were unperformed when this AsynchronousRunner was closed, either explicitly using close() or close( true ), or implicitly because some failure or corruption killed the Object (most likely a Thread interruption.
public synchronized void	postRunnable(Runnable r) Implements com.mchange.v2.async.AsynchronousRunner.postRunnable.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

gentle_close_requested	back to summary
private boolean gentle_close_requested

logger	back to summary
private static final MLogger logger

shutdown_on_interrupt	back to summary
private boolean shutdown_on_interrupt

strandedTasks	back to summary
private List<E> strandedTasks

t	back to summary
private CarefulRunnableQueue.TaskThread t

taskList	back to summary
private List<E> taskList

CarefulRunnableQueue	back to summary
public CarefulRunnableQueue(boolean daemon, boolean shutdown_on_interrupt)

Method Detail

asRunnableQueue	back to summary
public RunnableQueue asRunnableQueue() Implements com.mchange.v2.async.Queuable.asRunnableQueue.

awaitTask	back to summary
private synchronized void awaitTask() throws InterruptedException

close	back to summary
public synchronized void close(boolean skip_remaining_tasks) Implements com.mchange.v2.async.AsynchronousRunner.close. Doc from com.mchange.v2.async.AsynchronousRunner.close. Finish with this AsynchronousRunner, and clean-up any Threads or resources it may hold. Parameters skip_remaining_tasks:boolean Should be regarded as a hint, not a guarantee. If true, pending, not-yet-performed tasks will be skipped, if possible. Currently executing tasks may or may not be interrupted. If false, all previously scheduled tasks will be completed prior to clean-up. The method returns immediately regardless.

back to summary

public synchronized void close(boolean skip_remaining_tasks)

Implements com.mchange.v2.async.AsynchronousRunner.close.

Doc from com.mchange.v2.async.AsynchronousRunner.close.

Finish with this AsynchronousRunner, and clean-up any Threads or resources it may hold.

Parameters

skip_remaining_tasks:boolean: Should be regarded as a hint, not a guarantee. If true, pending, not-yet-performed tasks will be skipped, if possible. Currently executing tasks may or may not be interrupted. If false, all previously scheduled tasks will be completed prior to clean-up. The method returns immediately regardless.

close	back to summary
public synchronized void close() Implements com.mchange.v2.async.AsynchronousRunner.close. Doc from com.mchange.v2.async.AsynchronousRunner.close. Clean-up resources held by this asynchronous runner as soon as possible. Remaining tasks are skipped if possible, and any tasks executing when close() is called may or may not be interrupted. Equivalent to close( true ).

back to summary

public synchronized void close()

Implements com.mchange.v2.async.AsynchronousRunner.close.

Doc from com.mchange.v2.async.AsynchronousRunner.close.

Clean-up resources held by this asynchronous runner as soon as possible. Remaining tasks are skipped if possible, and any tasks executing when close() is called may or may not be interrupted. Equivalent to close( true ).

dequeueRunnable	back to summary
private synchronized Runnable dequeueRunnable()

getStrandedTasks	back to summary
public synchronized List<E> getStrandedTasks() Implements com.mchange.v2.async.StrandedTaskReporting.getStrandedTasks. Doc from com.mchange.v2.async.StrandedTaskReporting.getStrandedTasks. makes available any tasks that were unperformed when this AsynchronousRunner was closed, either explicitly using close() or close( true ), or implicitly because some failure or corruption killed the Object (most likely a Thread interruption. Returns:List<E> null if the AsynchronousRunner is still alive, a List of Runnables otherwise, which will be empty only if all tasks were performed before the AsynchronousRunner shut down.

getStrandedTasks

back to summary

public synchronized List<E> getStrandedTasks()

Implements com.mchange.v2.async.StrandedTaskReporting.getStrandedTasks.

Doc from com.mchange.v2.async.StrandedTaskReporting.getStrandedTasks.

makes available any tasks that were unperformed when this AsynchronousRunner was closed, either explicitly using close() or close( true ), or implicitly because some failure or corruption killed the Object (most likely a Thread interruption.

Returns:List<E>: null if the AsynchronousRunner is still alive, a List of Runnables otherwise, which will be empty only if all tasks were performed before the AsynchronousRunner shut down.

postRunnable	back to summary
public synchronized void postRunnable(Runnable r) Implements com.mchange.v2.async.AsynchronousRunner.postRunnable.

com.mchange.v2.async back to summary

pack-priv Class CarefulRunnableQueue.TaskThread

Class Inheritance

extends Thread

java.lang.Object
java.lang.Thread
com.mchange.v2.async.CarefulRunnableQueue.TaskThread

Field Summary

Modifier and Type	Field and Description
pack-priv boolean	should_stop

Inherited from java.lang.Thread:: MAX_PRIORITY MIN_PRIORITY NORM_PRIORITY

Constructor Summary

Access	Constructor and Description
pack-priv	TaskThread()

Method Summary

Modifier and Type	Method and Description
public void	run() Overrides java.lang.Thread.run. Implements java.lang.Runnable.run. This method is run by the thread when it executes.
public synchronized void	safeStop()
private synchronized boolean	shouldStop()

Field Detail

should_stop	back to summary
pack-priv boolean should_stop

Constructor Detail

TaskThread	back to summary
pack-priv TaskThread()

Method Detail

run back to summary

run	back to summary
public void run() Overrides java.lang.Thread.run. Implements java.lang.Runnable.run. Doc from java.lang.Thread.run. This method is run by the thread when it executes. Subclasses of `Thread` may override this method. This method is not intended to be invoked directly. If this thread is a platform thread created with a `Runnable` task then invoking this method will invoke the task's `run` method. If this thread is a virtual thread then invoking this method directly does nothing.

public void run()

Overrides java.lang.Thread.run.

Implements java.lang.Runnable.run.

Doc from java.lang.Thread.run.

This method is run by the thread when it executes. Subclasses of Thread may override this method.

This method is not intended to be invoked directly. If this thread is a platform thread created with a Runnable task then invoking this method will invoke the task's run method. If this thread is a virtual thread then invoking this method directly does nothing.

safeStop	back to summary
public synchronized void safeStop()

shouldStop	back to summary
private synchronized boolean shouldStop()

public Class CarefulRunnableQueue

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv Class CarefulRunnableQueue.TaskThread

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail