summaryrefslogtreecommitdiffstats
path: root/src/java/com
diff options
context:
space:
mode:
Diffstat (limited to 'src/java/com')
-rw-r--r--src/java/com/jogamp/common/util/ReflectionUtil.java28
-rw-r--r--src/java/com/jogamp/common/util/RunnableTask.java56
2 files changed, 74 insertions, 10 deletions
diff --git a/src/java/com/jogamp/common/util/ReflectionUtil.java b/src/java/com/jogamp/common/util/ReflectionUtil.java
index 6345efa..c771544 100644
--- a/src/java/com/jogamp/common/util/ReflectionUtil.java
+++ b/src/java/com/jogamp/common/util/ReflectionUtil.java
@@ -331,5 +331,33 @@ public final class ReflectionUtil {
return callMethod(null, getMethod(clazzName, methodName, argTypes, cl), args);
}
+ /** Convenient Method access class */
+ public static class MethodAccessor {
+ Method m = null;
+
+ /** Check {@link #available()} before using instance. */
+ public MethodAccessor(Class<?> clazz, String methodName, Class<?> ... argTypes) {
+ try {
+ m = ReflectionUtil.getMethod(clazz, methodName, argTypes);
+ } catch (JogampRuntimeException jre) { /* method n/a */ }
+ }
+
+ /** Returns true if method is available, otherwise false. */
+ public boolean available() {
+ return null != m;
+ }
+
+ /**
+ * Check {@link #available()} before calling to avoid throwing a JogampRuntimeException.
+ * @throws JogampRuntimeException if method is not available
+ */
+ public Object callMethod(Object instance, Object ... args) {
+ if(null == m) {
+ throw new JogampRuntimeException("Method not available. Instance: "+instance);
+ }
+ return ReflectionUtil.callMethod(instance, m, args);
+ }
+ }
+
}
diff --git a/src/java/com/jogamp/common/util/RunnableTask.java b/src/java/com/jogamp/common/util/RunnableTask.java
index 5ae102f..880bd64 100644
--- a/src/java/com/jogamp/common/util/RunnableTask.java
+++ b/src/java/com/jogamp/common/util/RunnableTask.java
@@ -34,35 +34,66 @@ package com.jogamp.common.util;
*/
public class RunnableTask implements Runnable {
Runnable runnable;
- final Object notifyObject;
+ final Object syncObject;
boolean catchExceptions;
Object attachment;
Throwable runnableException;
long ts0, ts1, ts2;
+ /**
+ * Create a RunnableTask object w/o synchronization,
+ * ie. not suitable for <code>invokeAndWait()</code>.
+ *
+ * @param runnable the user action
+ */
public RunnableTask(Runnable runnable) {
this(runnable, null, false);
}
- public RunnableTask(Runnable runnable, Object notifyObject) {
- this(runnable, notifyObject, false);
+ /**
+ * Create a RunnableTask object w/ synchronization,
+ * ie. suitable for <code>invokeAndWait()</code>.
+ *
+ * @param runnable the user action
+ * @param syncObject the synchronization object the caller shall wait for in case of <code>invokeAndWait()</code>
+ */
+ public RunnableTask(Runnable runnable, Object syncObject) {
+ this(runnable, syncObject, false);
}
- public RunnableTask(Runnable runnable, Object notifyObject, boolean catchExceptions) {
+ /**
+ * Create a RunnableTask object w/ synchronization,
+ * ie. suitable for <code>invokeAndWait()</code>.
+ *
+ * @param runnable the user action
+ * @param syncObject the synchronization object the caller shall wait for in case of <code>invokeAndWai()t</code>
+ * @param catchExceptions if true, exception during <code>runnable</code> execution are catched, otherwise not.
+ * Use {@link #getThrowable()} to determine whether an exception has been catched.
+ */
+ public RunnableTask(Runnable runnable, Object syncObject, boolean catchExceptions) {
this.runnable = runnable ;
- this.notifyObject = notifyObject ;
+ this.syncObject = syncObject ;
this.catchExceptions = catchExceptions ;
ts0 = System.currentTimeMillis();
ts1 = 0;
ts2 = 0;
}
+ /** Return the user action */
public Runnable getRunnable() {
return runnable;
}
/**
+ * Return the synchronization object if any.
+ * @see #RunnableTask(Runnable, Object, boolean)
+ */
+ public Object getSyncObject() {
+ return syncObject;
+ }
+
+ /**
* Attach a custom object to this task.
* Useful to piggybag further information, ie tag a task final.
*/
@@ -70,13 +101,17 @@ public class RunnableTask implements Runnable {
attachment = o;
}
+ /**
+ * Return the attachment object if any.
+ * @see #setAttachment(Object)
+ */
public Object getAttachment() {
return attachment;
}
public void run() {
ts1 = System.currentTimeMillis();
- if(null == notifyObject) {
+ if(null == syncObject) {
try {
runnable.run();
} catch (Throwable t) {
@@ -88,7 +123,7 @@ public class RunnableTask implements Runnable {
ts2 = System.currentTimeMillis();
}
} else {
- synchronized (notifyObject) {
+ synchronized (syncObject) {
try {
runnable.run();
} catch (Throwable t) {
@@ -98,7 +133,7 @@ public class RunnableTask implements Runnable {
}
} finally {
ts2 = System.currentTimeMillis();
- notifyObject.notifyAll();
+ syncObject.notifyAll();
}
}
}
@@ -113,10 +148,11 @@ public class RunnableTask implements Runnable {
* @return True if invoking thread waits until done,
* ie a <code>notifyObject</code> was passed, otherwise false;
*/
- public boolean hasWaiter() { return null != notifyObject; }
+ public boolean hasWaiter() { return null != syncObject; }
/**
- * @return A Throwable thrown while execution if any
+ * @return A thrown exception while execution of the user action, if any and if catched
+ * @see #RunnableTask(Runnable, Object, boolean)
*/
public Throwable getThrowable() { return runnableException; }