Nested and Inner Type Summary

Modifier and Type	Class and Description
private class	QuantumRenderer.PipelineRunnable
private class	QuantumRenderer.QuantumThreadFactory

Field Summary

Modifier and Type	Field and Description
private Throwable	_initThrowable
private Thread	_renderer
private CountDownLatch	initLatch
private static final AtomicReference<QuantumRenderer>	instanceReference
private static boolean	usePurgatory

Constructor Summary

Access	Constructor and Description
private	QuantumRenderer()

Method Summary

Modifier and Type	Method and Description
public void	afterExecute(Runnable the runnable that has completed r, Throwable the exception that caused termination, or null if execution completed normally t) Overrides java.util.concurrent.ThreadPoolExecutor.afterExecute. Method invoked upon completion of execution of the given Runnable.
pack-priv void	checkRendererIdle()
protected void	createResourceFactory()
protected void	disposePresentable(final Presentable presentable)
public static synchronized QuantumRenderer	getInstance()
protected Throwable	initThrowable()
protected <T> RunnableFuture<T>	newTaskFor(Runnable the runnable task being wrapped runnable, T the default value for the returned future value) Overrides java.util.concurrent.AbstractExecutorService.newTaskFor. Returns a `RunnableFuture` for the given runnable and default value.
private void	setInitThrowable(Throwable th)
protected void	stopRenderer()
protected Future<V>	submitRenderJob(RenderJob r)

Field Detail

_initThrowable	back to summary
private Throwable _initThrowable

_renderer	back to summary
private Thread _renderer

initLatch	back to summary
private CountDownLatch initLatch

instanceReference	back to summary
private static final AtomicReference<QuantumRenderer> instanceReference

usePurgatory	back to summary
private static boolean usePurgatory

Constructor Detail

QuantumRenderer	back to summary
private QuantumRenderer()

Method Detail

afterExecute back to summary

afterExecute	back to summary
public void afterExecute(Runnable r, Throwable t) Overrides java.util.concurrent.ThreadPoolExecutor.afterExecute. Doc from java.util.concurrent.ThreadPoolExecutor.afterExecute. Method invoked upon completion of execution of the given Runnable. This method is invoked by the thread that executed the task. If non-null, the Throwable is the uncaught `RuntimeException` or `Error` that caused execution to terminate abruptly. This implementation does nothing, but may be customized in subclasses. Note To properly nest multiple overridings, subclasses should generally invoke `super.afterExecute` at the beginning of this method. Note When actions are enclosed in tasks (such as `FutureTask`) either explicitly or via methods such as `submit`, these task objects catch and maintain computational exceptions, and so they do not cause abrupt termination, and the internal exceptions are not passed to this method. If you would like to trap both kinds of failures in this method, you can further probe for such cases, as in this sample subclass that prints either the direct cause or the underlying exception if a task has been aborted: `class ExtendedExecutor extends ThreadPoolExecutor { // ... protected void afterExecute(Runnable r, Throwable t) { super.afterExecute(r, t); if (t == null && r instanceof Future<?> && ((Future<?>)r).isDone()) { try { Object result = ((Future<?>) r).get(); } catch (CancellationException ce) { t = ce; } catch (ExecutionException ee) { t = ee.getCause(); } catch (InterruptedException ie) { // ignore/reset Thread.currentThread().interrupt(); } } if (t != null) System.out.println(t); } }` Parameters r:Runnable the runnable that has completed t:Throwable the exception that caused termination, or null if execution completed normally Annotations @Override

public void afterExecute(Runnable r, Throwable t)

Overrides java.util.concurrent.ThreadPoolExecutor.afterExecute.

Doc from java.util.concurrent.ThreadPoolExecutor.afterExecute.

Method invoked upon completion of execution of the given Runnable. This method is invoked by the thread that executed the task. If non-null, the Throwable is the uncaught RuntimeException or Error that caused execution to terminate abruptly.

This implementation does nothing, but may be customized in subclasses.

Note

To properly nest multiple overridings, subclasses should generally invoke super.afterExecute at the beginning of this method.

Note

When actions are enclosed in tasks (such as FutureTask) either explicitly or via methods such as submit, these task objects catch and maintain computational exceptions, and so they do not cause abrupt termination, and the internal exceptions are not passed to this method. If you would like to trap both kinds of failures in this method, you can further probe for such cases, as in this sample subclass that prints either the direct cause or the underlying exception if a task has been aborted:

 class ExtendedExecutor extends ThreadPoolExecutor {
  // ...
  protected void afterExecute(Runnable r, Throwable t) {
    super.afterExecute(r, t);
    if (t == null
        && r instanceof Future<?>
        && ((Future<?>)r).isDone()) {
      try {
        Object result = ((Future<?>) r).get();
      } catch (CancellationException ce) {
        t = ce;
      } catch (ExecutionException ee) {
        t = ee.getCause();
      } catch (InterruptedException ie) {
        // ignore/reset
        Thread.currentThread().interrupt();
      }
    }
    if (t != null)
      System.out.println(t);
  }
}

Parameters

r:Runnable: the runnable that has completed
t:Throwable: the exception that caused termination, or null if execution completed normally

Annotations

@Override

checkRendererIdle	back to summary
pack-priv void checkRendererIdle()

createResourceFactory	back to summary
protected void createResourceFactory()

disposePresentable	back to summary
protected void disposePresentable(final Presentable presentable)

getInstance	back to summary
public static synchronized QuantumRenderer getInstance()

initThrowable	back to summary
protected Throwable initThrowable()

newTaskFor back to summary

newTaskFor	back to summary
protected <T> RunnableFuture<T> newTaskFor(Runnable runnable, T value) Overrides java.util.concurrent.AbstractExecutorService.newTaskFor. Doc from java.util.concurrent.AbstractExecutorService.newTaskFor. Returns a `RunnableFuture` for the given runnable and default value. Parameters <T> the type of the given value runnable:Runnable the runnable task being wrapped value:T the default value for the returned future Returns:RunnableFuture<T> a `RunnableFuture` which, when run, will run the underlying runnable and which, as a `Future`, will yield the given value as its result and provide for cancellation of the underlying task Annotations @Override

protected <T> RunnableFuture<T> newTaskFor(Runnable runnable, T value)

Overrides java.util.concurrent.AbstractExecutorService.newTaskFor.

Doc from java.util.concurrent.AbstractExecutorService.newTaskFor.

Returns a RunnableFuture for the given runnable and default value.

Parameters

<T>: the type of the given value
runnable:Runnable: the runnable task being wrapped
value:T: the default value for the returned future

Returns:RunnableFuture<T>

a RunnableFuture which, when run, will run the underlying runnable and which, as a Future, will yield the given value as its result and provide for cancellation of the underlying task

Annotations

@Override

setInitThrowable	back to summary
private void setInitThrowable(Throwable th)

stopRenderer	back to summary
protected void stopRenderer()

submitRenderJob	back to summary
protected Future<V> submitRenderJob(RenderJob r)

com.sun.javafx.tk.quantum back to summary

private Class QuantumRenderer.PipelineRunnable

Class Inheritance

extends Object
implements Runnable

java.lang.Object
com.sun.javafx.tk.quantum.QuantumRenderer.PipelineRunnable

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
private Runnable	work

Constructor Summary

Access	Constructor and Description
public	PipelineRunnable(Runnable runner)

Method Summary

Modifier and Type	Method and Description
public void	cleanup()
public void	init()
public void	run() Implements java.lang.Runnable.run. Runs this operation.

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

Field Detail

work	back to summary
private Runnable work

Constructor Detail

PipelineRunnable	back to summary
public PipelineRunnable(Runnable runner)

Method Detail

cleanup	back to summary
public void cleanup()

init	back to summary
public void init()

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

com.sun.javafx.tk.quantum back to summary

private Class QuantumRenderer.QuantumThreadFactory

Class Inheritance

extends Object
implements ThreadFactory

java.lang.Object
com.sun.javafx.tk.quantum.QuantumRenderer.QuantumThreadFactory

All Implemented Interfaces

java.util.concurrent.ThreadFactory

Field Summary

Modifier and Type	Field and Description
pack-priv final AtomicInteger	threadNumber

Constructor Summary

Access	Constructor and Description
private	QuantumThreadFactory()

Method Summary

Modifier and Type	Method and Description
public Thread	newThread(Runnable a runnable to be executed by new thread instance r) Implements java.util.concurrent.ThreadFactory.newThread. Constructs a new unstarted `Thread` to run the given runnable.

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

Field Detail

threadNumber	back to summary
pack-priv final AtomicInteger threadNumber

Constructor Detail

QuantumThreadFactory	back to summary
private QuantumThreadFactory()

Method Detail

newThread back to summary

newThread	back to summary
public Thread newThread(Runnable r) Implements java.util.concurrent.ThreadFactory.newThread. Doc from java.util.concurrent.ThreadFactory.newThread. Constructs a new unstarted `Thread` to run the given runnable. Parameters r:Runnable a runnable to be executed by new thread instance Returns:Thread constructed thread, or `null` if the request to create a thread is rejected Annotations @Override

public Thread newThread(Runnable r)

Implements java.util.concurrent.ThreadFactory.newThread.

Doc from java.util.concurrent.ThreadFactory.newThread.

Constructs a new unstarted Thread to run the given runnable.

Parameters

r:Runnable: a runnable to be executed by new thread instance

Returns:Thread

constructed thread, or null if the request to create a thread is rejected

Annotations

@Override

pack-priv final Class QuantumRenderer

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class QuantumRenderer.PipelineRunnable

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class QuantumRenderer.QuantumThreadFactory

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail