org.fusesource.hawtdispatch

Class DispatchQueueProxy

java.lang.Object

org.fusesource.hawtdispatch.DispatchQueueProxy

public class DispatchQueueProxy
extends java.lang.Object

This class creates proxy objects that allow you to easily service all method calls to an interface via a DispatchQueue.

The general idea is that proxy asynchronously invoke the delegate using the dispatch queue. The proxy implementation is generated using ASM using the following code generation pattern:

 class <>$__ACTOR_PROXY__ implements <> {

    private final <> target;
    private final DispatchQueue queue;

    public <>$__ACTOR_PROXY__(<> target, DispatchQueue queue) {
        this.target = target;
        this.queue = queue;
    }

    <>

      <> {
          queue.execute( new Runnable() {
             public void run() {
                 this.target.<>;
             }
          } );
      }
    <>
 }
 

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	DispatchQueueProxy.Generator<T>

Constructor Summary

Constructors

Constructor and Description
DispatchQueueProxy()

Method Summary

Modifier and Type	Method and Description
static <T> T	create(java.lang.Class<T> interfaceClass, T target, DispatchQueue queue) Create an asynchronous dispatch proxy to the target object via the dispatch queue.
static <T> T	create(java.lang.ClassLoader classLoader, java.lang.Class<T> interfaceClass, T target, DispatchQueue queue) Create an asynchronous dispatch proxy to the target object via the dispatch queue.
private static <T> java.lang.Class<T>	getProxyClass(java.lang.ClassLoader loader, java.lang.Class<T> interfaceClass)
private static java.lang.String	proxyName(java.lang.Class<?> clazz)

Methods inherited from class java.lang.Object

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

Constructor Detail

DispatchQueueProxy

public DispatchQueueProxy()

Method Detail

create

public static <T> T create(java.lang.Class<T> interfaceClass,
                           T target,
                           DispatchQueue queue)
                    throws java.lang.IllegalArgumentException

Create an asynchronous dispatch proxy to the target object via the dispatch queue. The class loader of the generated proxy will be the same as the class loader of the target object.

Type Parameters:

T - the type of the interface class

Parameters:

interfaceClass - the interface that will be implemented by the proxy

target - the delegate object the proxy will asynchronously invoke

queue - the dispatch queue that the asynchronous runnables will execute on

Returns:

the new asynchronous dispatch proxy

Throws:

java.lang.IllegalArgumentException

create

public static <T> T create(java.lang.ClassLoader classLoader,
                           java.lang.Class<T> interfaceClass,
                           T target,
                           DispatchQueue queue)
                    throws java.lang.IllegalArgumentException

Create an asynchronous dispatch proxy to the target object via the dispatch queue.

Type Parameters:

T - the type of the interface asynchronous

Parameters:

classLoader - the classloader which the proxy class should use

interfaceClass - the interface that will be implemented by the proxy

target - the delegate object the proxy will asynchronously invoke

queue - the dispatch queue that the asyncronous runnables will execute on

Returns:

the new asynchronous dispatch proxy

Throws:

java.lang.IllegalArgumentException

getProxyClass

private static <T> java.lang.Class<T> getProxyClass(java.lang.ClassLoader loader,
                                                    java.lang.Class<T> interfaceClass)
                                             throws java.lang.IllegalArgumentException

Throws:

java.lang.IllegalArgumentException

proxyName

private static java.lang.String proxyName(java.lang.Class<?> clazz)