Modifier and Type	Class and Description
pack-priv class	RoundRobinAsynchronousRunner.RunnableQueueView

Modifier and Type	Field and Description
private static final MLogger	logger
pack-priv final RunnableQueue[]	rqs
pack-priv int	task_turn
pack-priv int	view_turn

Access	Constructor and Description
public	RoundRobinAsynchronousRunner(int num_threads, boolean daemon)

Method Summary

Modifier and Type	Method and Description
public synchronized RunnableQueue	asRunnableQueue() Implements com.mchange.v2.async.Queuable.asRunnableQueue.
pack-priv static void	attemptClose(RunnableQueue rq, boolean skip_remaining_tasks)
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 void	close() Implements com.mchange.v2.async.AsynchronousRunner.close. Clean-up resources held by this asynchronous runner as soon as possible.
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

Field Detail

logger	back to summary
private static final MLogger logger

rqs	back to summary
pack-priv final RunnableQueue[] rqs

task_turn	back to summary
pack-priv int task_turn

view_turn	back to summary
pack-priv int view_turn

RoundRobinAsynchronousRunner	back to summary
public RoundRobinAsynchronousRunner(int num_threads, boolean daemon)

Method Detail

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

attemptClose	back to summary
pack-priv static void attemptClose(RunnableQueue rq, boolean skip_remaining_tasks)

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 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 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 ).

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 RoundRobinAsynchronousRunner.RunnableQueueView

Class Inheritance

extends Object
implements RunnableQueue

java.lang.Object
com.mchange.v2.async.RoundRobinAsynchronousRunner.RunnableQueueView

All Implemented Interfaces

com.mchange.v2.async.RunnableQueue, com.mchange.v2.async.AsynchronousRunner, com.mchange.v1.util.ClosableResource

Field Summary

Modifier and Type	Field and Description
pack-priv final int	rq_num

Constructor Summary

Access	Constructor and Description
pack-priv	RunnableQueueView(int rq_num)

Method Summary

Modifier and Type	Method and Description
public 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 void	close() Implements com.mchange.v2.async.AsynchronousRunner.close. Clean-up resources held by this asynchronous runner as soon as possible.
public 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

Field Detail

rq_num	back to summary
pack-priv final int rq_num

Constructor Detail

RunnableQueueView	back to summary
pack-priv RunnableQueueView(int rq_num)

Method Detail

close	back to summary
public 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 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 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 void close()

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

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