Modifier and Type	Class and Description
protected abstract class	AbstractExecutorTaskRunnerFactory.AbstractExecutorAsynchronousRunner This implementation includes uninformative stub implementations of `public int getThreadCount() { return -1; } public int getIdleCount() { return -1; } public int getPendingTaskCount() { return -1; }`

Modifier and Type	Field and Description
private static final StackTraceElement[]	EMPTY_STACK_TRACES
private static final MLogger	logger
private static final String	SEP

Access	Constructor and Description
public	AbstractExecutorTaskRunnerFactory()

Modifier and Type	Method and Description
protected abstract ThreadPoolReportingAsynchronousRunner	createTaskRunner(TaskRunnerInit init, Timer timer)
public ThreadPoolReportingAsynchronousRunner	createTaskRunner(int num_threads_if_supported, int max_administrative_task_time_if_supported, String contextClassLoaderSourceIfSupported, boolean privilege_spawned_threads_if_supported, String threadLabelIfSupported, ConnectionPoolDataSource cpds, Timer timer) Implements com.mchange.v2.c3p0.TaskRunnerFactory.createTaskRunner.
public boolean	equals(Object the reference object with which to compare. o) Overrides java.lang.Object.equals. Indicates whether some other object is "equal to" this one.
protected abstract Executor	findCreateExecutor(TaskRunnerInit init)
public int	hashCode() Overrides java.lang.Object.hashCode. Returns a hash code value for this object.
protected HashMap<K, V>	otherPropertiesFromConnectionPoolDataSource(ConnectionPoolDataSource cpds)
protected abstract boolean	taskRunnerOwnsExecutor() If the task runner will "own" the Executor it finds/creates, then when the task runner is closed() so to will the Executor be.

EMPTY_STACK_TRACES	back to summary
private static final StackTraceElement[] EMPTY_STACK_TRACES

logger	back to summary
private static final MLogger logger

SEP	back to summary
private static final String SEP

AbstractExecutorTaskRunnerFactory	back to summary
public AbstractExecutorTaskRunnerFactory()

Method Detail

createTaskRunner	back to summary
protected abstract ThreadPoolReportingAsynchronousRunner createTaskRunner(TaskRunnerInit init, Timer timer)

createTaskRunner	back to summary
public ThreadPoolReportingAsynchronousRunner createTaskRunner(int num_threads_if_supported, int max_administrative_task_time_if_supported, String contextClassLoaderSourceIfSupported, boolean privilege_spawned_threads_if_supported, String threadLabelIfSupported, ConnectionPoolDataSource cpds, Timer timer) Implements com.mchange.v2.c3p0.TaskRunnerFactory.createTaskRunner.

equals back to summary

equals	back to summary
public boolean equals(Object o) Overrides java.lang.Object.equals. Doc from java.lang.Object.equals. Indicates whether some other object is "equal to" this one. The `equals` method implements an equivalence relation on non-null object references: It is reflexive: for any non-null reference value `x`, `x.equals(x)` should return `true`. It is symmetric: for any non-null reference values `x` and `y`, `x.equals(y)` should return `true` if and only if `y.equals(x)` returns `true`. It is transitive: for any non-null reference values `x`, `y`, and `z`, if `x.equals(y)` returns `true` and `y.equals(z)` returns `true`, then `x.equals(z)` should return `true`. It is consistent: for any non-null reference values `x` and `y`, multiple invocations of `x.equals(y)` consistently return `true` or consistently return `false`, provided no information used in `equals` comparisons on the objects is modified. For any non-null reference value `x`, `x.equals(null)` should return `false`. An equivalence relation partitions the elements it operates on into equivalence classes; all the members of an equivalence class are equal to each other. Members of an equivalence class are substitutable for each other, at least for some purposes. Parameters o:Object the reference object with which to compare. Returns:boolean `true` if this object is the same as the obj argument; `false` otherwise.

public boolean equals(Object o)

Overrides java.lang.Object.equals.

Doc from java.lang.Object.equals.

Indicates whether some other object is "equal to" this one.

The equals method implements an equivalence relation on non-null object references:

It is reflexive: for any non-null reference value x, x.equals(x) should return true.
It is symmetric: for any non-null reference values x and y, x.equals(y) should return true if and only if y.equals(x) returns true.
It is transitive: for any non-null reference values x, y, and z, if x.equals(y) returns true and y.equals(z) returns true, then x.equals(z) should return true.
It is consistent: for any non-null reference values x and y, multiple invocations of x.equals(y) consistently return true or consistently return false, provided no information used in equals comparisons on the objects is modified.
For any non-null reference value x, x.equals(null) should return false.

An equivalence relation partitions the elements it operates on into equivalence classes; all the members of an equivalence class are equal to each other. Members of an equivalence class are substitutable for each other, at least for some purposes.

Parameters

o:Object: the reference object with which to compare.

Returns:boolean

true if this object is the same as the obj argument; false otherwise.

findCreateExecutor	back to summary
protected abstract Executor findCreateExecutor(TaskRunnerInit init)

hashCode back to summary

hashCode	back to summary
public int hashCode() Overrides java.lang.Object.hashCode. Doc from java.lang.Object.hashCode. Returns a hash code value for this object. This method is supported for the benefit of hash tables such as those provided by `java.util.HashMap`. The general contract of `hashCode` is: Whenever it is invoked on the same object more than once during an execution of a Java application, the `hashCode` method must consistently return the same integer, provided no information used in `equals` comparisons on the object is modified. This integer need not remain consistent from one execution of an application to another execution of the same application. If two objects are equal according to the `equals` method, then calling the `hashCode` method on each of the two objects must produce the same integer result. It is not required that if two objects are unequal according to the `equals` method, then calling the `hashCode` method on each of the two objects must produce distinct integer results. However, the programmer should be aware that producing distinct integer results for unequal objects may improve the performance of hash tables. Returns:int a hash code value for this object

public int hashCode()

Overrides java.lang.Object.hashCode.

Doc from java.lang.Object.hashCode.

Returns a hash code value for this object. This method is supported for the benefit of hash tables such as those provided by java.util.HashMap.

The general contract of hashCode is:

Whenever it is invoked on the same object more than once during an execution of a Java application, the hashCode method must consistently return the same integer, provided no information used in equals comparisons on the object is modified. This integer need not remain consistent from one execution of an application to another execution of the same application.
If two objects are equal according to the equals method, then calling the hashCode method on each of the two objects must produce the same integer result.
It is not required that if two objects are unequal according to the equals method, then calling the hashCode method on each of the two objects must produce distinct integer results. However, the programmer should be aware that producing distinct integer results for unequal objects may improve the performance of hash tables.

Returns:int: a hash code value for this object

otherPropertiesFromConnectionPoolDataSource	back to summary
protected HashMap<K, V> otherPropertiesFromConnectionPoolDataSource(ConnectionPoolDataSource cpds)

taskRunnerOwnsExecutor	back to summary
protected abstract boolean taskRunnerOwnsExecutor() If the task runner will "own" the Executor it finds/creates, then when the task runner is closed() so to will the Executor be.

com.mchange.v2.c3p0 back to summary

protected abstract Class AbstractExecutorTaskRunnerFactory.AbstractExecutorAsynchronousRunner

Class Inheritance

extends Object
implements ThreadPoolReportingAsynchronousRunner

java.lang.Object
com.mchange.v2.c3p0.AbstractExecutorTaskRunnerFactory.AbstractExecutorAsynchronousRunner

All Implemented Interfaces

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

Known Direct Subclasses

com.mchange.v2.c3p0.FixedThreadPoolExecutorTaskRunnerFactory.FixedThreadPoolExecutorAsynchronousRunner

This implementation includes uninformative stub implementations of


  public int getThreadCount()      { return -1; }
  public int getIdleCount()        { return -1; }
  public int getPendingTaskCount() { return -1; }

Consider overriding those if you can!

Nested and Inner Type Summary

Modifier and Type	Class and Description
private class	AbstractExecutorTaskRunnerFactory.AbstractExecutorAsynchronousRunner.WrapperRunnable

Field Summary

Modifier and Type	Field and Description
private HashSet<E>	activeWrapperRunnables
protected final TaskRunnerInit	init
private boolean	is_closed
private final int	matt_ms
protected final Timer	timer
private Executor	x
private Object	xlock

Constructor Summary

Access	Constructor and Description
protected	AbstractExecutorAsynchronousRunner(TaskRunnerInit init, Timer timer)

Method Summary

Modifier and Type	Method and Description
protected synchronized int	activeCount()
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.
protected Executor	executor()
public int	getActiveCount() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getActiveCount.
public int	getIdleCount() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getIdleCount.
public int	getPendingTaskCount() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getPendingTaskCount.
public String	getStackTraces() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getStackTraces.
public String	getStatus() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getStatus.
public int	getThreadCount() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getThreadCount.
protected synchronized boolean	isClosed()
public synchronized void	postRunnable(Runnable r) Implements com.mchange.v2.async.AsynchronousRunner.postRunnable.
protected synchronized void	registerActive(AbstractExecutorTaskRunnerFactory.AbstractExecutorAsynchronousRunner.WrapperRunnable wr)
protected synchronized HashSet<E>	snapshotActives()
protected synchronized void	unregisterActive(AbstractExecutorTaskRunnerFactory.AbstractExecutorAsynchronousRunner.WrapperRunnable wr)

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

Field Detail

activeWrapperRunnables	back to summary
private HashSet<E> activeWrapperRunnables

init	back to summary
protected final TaskRunnerInit init

is_closed	back to summary
private boolean is_closed

matt_ms	back to summary
private final int matt_ms

timer	back to summary
protected final Timer timer

x	back to summary
private Executor x

xlock	back to summary
private Object xlock

Constructor Detail

AbstractExecutorAsynchronousRunner	back to summary
protected AbstractExecutorAsynchronousRunner(TaskRunnerInit init, Timer timer)

Method Detail

activeCount	back to summary
protected synchronized int activeCount()

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

executor	back to summary
protected Executor executor()

getActiveCount	back to summary
public int getActiveCount() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getActiveCount.

getIdleCount	back to summary
public int getIdleCount() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getIdleCount.

getPendingTaskCount	back to summary
public int getPendingTaskCount() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getPendingTaskCount.

getStackTraces	back to summary
public String getStackTraces() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getStackTraces.

getStatus	back to summary
public String getStatus() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getStatus.

getThreadCount	back to summary
public int getThreadCount() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getThreadCount.

isClosed	back to summary
protected synchronized boolean isClosed()

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

registerActive	back to summary
protected synchronized void registerActive(AbstractExecutorTaskRunnerFactory.AbstractExecutorAsynchronousRunner.WrapperRunnable wr)

snapshotActives	back to summary
protected synchronized HashSet<E> snapshotActives()

unregisterActive	back to summary
protected synchronized void unregisterActive(AbstractExecutorTaskRunnerFactory.AbstractExecutorAsynchronousRunner.WrapperRunnable wr)

com.mchange.v2.c3p0 back to summary

private final Class AbstractExecutorTaskRunnerFactory.AbstractExecutorAsynchronousRunner.WrapperRunnable

Class Inheritance

extends Object
implements Runnable

java.lang.Object
com.mchange.v2.c3p0.AbstractExecutorTaskRunnerFactory.AbstractExecutorAsynchronousRunner.WrapperRunnable

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
pack-priv Thread	carrier
pack-priv Runnable	inner

Constructor Summary

Access	Constructor and Description
pack-priv	WrapperRunnable(Runnable inner)

Method Summary

Modifier and Type	Method and Description
public synchronized String	getCarrierName()
public synchronized StackTraceElement[]	getStackTrace()
public synchronized void	interrupt()
public void	run() Implements java.lang.Runnable.run. Runs this operation.
private synchronized void	setCarrier(Thread t)

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

Field Detail

carrier	back to summary
pack-priv Thread carrier

inner	back to summary
pack-priv Runnable inner

Constructor Detail

WrapperRunnable	back to summary
pack-priv WrapperRunnable(Runnable inner)

Method Detail

getCarrierName	back to summary
public synchronized String getCarrierName()

getStackTrace	back to summary
public synchronized StackTraceElement[] getStackTrace()

interrupt	back to summary
public synchronized void interrupt()

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

setCarrier	back to summary
private synchronized void setCarrier(Thread t)

public abstract Class AbstractExecutorTaskRunnerFactory

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

protected abstract Class AbstractExecutorTaskRunnerFactory.AbstractExecutorAsynchronousRunner

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class AbstractExecutorTaskRunnerFactory.AbstractExecutorAsynchronousRunner.WrapperRunnable

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail