1 files changed, 95 insertions, 0 deletions
diff --git a/java/JACE/tests/Concurrency/TokenTest.java b/java/JACE/tests/Concurrency/TokenTest.java
new file mode 100644
index 00000000000..162170f1996
--- /dev/null
+++ b/java/JACE/tests/Concurrency/TokenTest.java
@@ -0,0 +1,95 @@
+/*************************************************
+ *
+ * = PACKAGE
+ *    tests.Concurrency
+ *
+ * = FILENAME
+ *    TokenTest.java
+ *
+ *@author Prashant Jain
+ *
+ *************************************************/
+package JACE.tests.Concurrency;
+
+import java.io.*;
+import JACE.OS.*;
+import JACE.Concurrency.ThreadManager;
+import JACE.Concurrency.*;
+import JACE.ASX.TimeValue;
+
+public class TokenTest implements Runnable
+{
+  static class MyToken extends Token
+  {
+    public void sleepHook ()
+    {
+      ACE.DEBUG (Thread.currentThread ().getName () + 
+		 " blocking, sleepHook called");
+    }  
+  }
+
+  public void run ()
+  {
+    String name = Thread.currentThread().getName();
+    try
+      {
+	if (this.token_.acquire () != AbstractLock.FAILURE)
+	  ACE.DEBUG (name + " got token");
+	else
+	  ACE.DEBUG (name + " couldn't get token");
+
+	ACE.DEBUG (name + " calling acquire again (test nesting)");
+	if (this.token_.acquire() != AbstractLock.FAILURE)
+	  ACE.DEBUG (name + " got token again");
+	else
+	  ACE.DEBUG (name + " couldn't get token");
+
+	Thread.sleep (1000);
+
+	ACE.DEBUG (name + " gives it up for max 2 sec to first waiter");
+	this.token_.renew (1, TimeValue.relativeTimeOfDay(2, 0));
+
+	ACE.DEBUG (name + " releases the token once");
+	this.token_.release ();
+	ACE.DEBUG (name + " calls release again (nesting level was 2)");
+	this.token_.release ();
+      }
+    catch (InterruptedException e)
+      {
+	this.token_.release ();
+      }
+    catch (JACE.ASX.TimeoutException e) 
+      {
+	ACE.DEBUG (name + " timed out");
+      }
+  }
+
+  /**
+   * Command line: optional number of threads to create (defaults to 2)
+   */
+  public static void main (String args [])
+  {
+    ThreadManager tm = new ThreadManager ();
+    int n = 2;
+
+    ACE.enableDebugging ();
+
+    try
+      {
+	if (args.length == 1)
+	  {
+	    n = Integer.parseInt (args[0]);
+	  }
+      }
+    catch (NumberFormatException e)
+      {
+	ACE.ERROR ("Illegal argument.");
+      }
+
+    tm.spawnN (n,
+	       new TokenTest (),
+	       false);
+  }
+
+  private static MyToken token_ = new MyToken ();
+}