0 Replies Latest reply on Jun 25, 2010 3:45 PM by J Sanz A

    AsyncUtils.mixinAsync future lock for a minute

    J Sanz A Newbie

      Hello,

       

      I am testing async invocation using the examples in jboss  6.0

       

      I got a strange execution ... when the client finish, it  hold for a seconds (around 50-60 seconds) before real end ...

       

      If i  put a System.exit , the execution is ok ...  i found that the  AsyncUtils.mixinAsync and Future are in the trouble ...

      When i list all threads remaining , i show a  "1  Thread[pool-1-thread-1,5,main]

      "  nivel 1 ...

       

      If  i debug  the source, i get that the thread is in following mode:

       

      "pool-1-thread-1"  prio=6 tid=0x04260000 nid=0xf80 waiting on condition [0x0667f000]
          java.lang.Thread.State: WAITING (parking)
          at  sun.misc.Unsafe.park(Native Method)
          - parking to wait for   <0x1590c730> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
           at java.util.concurrent.locks.LockSupport.park(LockSupport.java:158)
           at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:1925)
           at java.util.concurrent.PriorityBlockingQueue.take(PriorityBlockingQueue.java:220)
           at org.jboss.resource.adapter.mail.inflow.NewMsgsWorker.run(NewMsgsWorker.java:78)
           at org.jboss.resource.work.WorkWrapper.run(WorkWrapper.java:172)
           at org.jboss.threads.SimpleDirectExecutor.execute(SimpleDirectExecutor.java:33)
           at org.jboss.threads.QueueExecutor.runTask(QueueExecutor.java:780)
           at org.jboss.threads.QueueExecutor.access$100(QueueExecutor.java:45)
           at org.jboss.threads.QueueExecutor$Worker.run(QueueExecutor.java:800)
           at java.lang.Thread.run(Thread.java:619)
          at  org.jboss.threads.JBossThread.run(JBossThread.java:122)

       

      and the main thread is blocked to end until this thread stop  .... wasted 50 seconds ...

       

      how can i do to fix it

       

      thank  you

       

      /* ------------------------------ cut & paste  ------------------------------------------------------------ */

       

      package paq;

       

      import java.util.Date;
      import  java.util.Hashtable;
      import java.util.concurrent.Future;
      import  java.util.concurrent.TimeUnit;

       

      import javax.naming.Context;
      import  javax.naming.InitialContext;

      import org.jboss.ejb3.common.proxy.plugins.async.AsyncUtils;

       

      public  class Client {
          public static void main(String[] args) throws  Exception {
              Hashtable<String, String> environment = new  Hashtable<String, String>();
               environment.put(Context.INITIAL_CONTEXT_FACTORY,   "org.jnp.interfaces.NamingContextFactory");
               environment.put(Context.URL_PKG_PREFIXES,   "org.jboss.naming:org.jnp.interfaces");
               environment.put(Context.PROVIDER_URL, "jnp://localhost:1099");

              InitialContext ctx = new InitialContext(environment);
               Echo echo = (Echo) ctx.lookup("TestEAR/EchoBean/remote");
               System.out.println("-------- Synchronous call");
              String  ret = echo.echo("1.- normal call");
               System.out.println(ret);

       

              Echo asynchEcho =  AsyncUtils.mixinAsync(echo);
             
               System.out.println("-------- Asynchronous call");
              ret =  asynchEcho.echo("2.- asynchronous call test");
               // deberia devolver null en ret
               System.out.println("Direct return of async invocation is: " + ret);

       

               System.out.println("-------- Synchronous call");
              ret =  echo.echo("3.- normal call 2");
               System.out.println(ret);

       

               System.out.println("-------- Result of Asynchronous call");
               Future<?> future = AsyncUtils.getFutureResult(asynchEcho);

       

               System.out.println("Waiting for asynbch invocation to complete");
               ret = (String) future.get(500, TimeUnit.MILLISECONDS);
               System.out.println(future.isDone());
               System.out.println("->" + ret + " " + new Date());

       

              //  ThreadUtilities.getThread("pool-1-thread-1").interrupt();

              System.out.println("FIN");
              // new  Thread().start();

       

              //listThreads();
              /*
               System.out.println("----------------");
               listThreads();           
               System.out.println(""+ new Date());
               Thread.currentThread().sleep(60*1000);
               System.out.println("----------------");
               System.out.println(""+ new Date());
               */
              listThreads();
              System.exit(0);
          }

       

           public static void listThreads() {
              // Find the root thread  group
              ThreadGroup root = Thread.currentThread().getThreadGroup().getParent();
               while (root.getParent() != null) {
                  root =  root.getParent();
              }
              // Visit each thread group
               visit(root, 0);
          }

       

          // This method recursively  visits all thread groups under `group'.
           public static void visit(ThreadGroup group, int level) {
               // Get threads in `group'
              int numThreads =  group.activeCount();
              Thread[] threads = new Thread[numThreads  * 2];
              numThreads = group.enumerate(threads, false);

              // Enumerate each thread in `group'
              for (int i =  0; i < numThreads; i++) {
                  // Get thread
                   Thread thread = threads[i];
                  System.out.println(level + "  " + thread);
               }
              // Get thread subgroups of `group'
              int  numGroups = group.activeGroupCount();
              ThreadGroup[] groups =  new ThreadGroup[numGroups * 2];
              numGroups =  group.enumerate(groups, false);
               // Recursively visit each subgroup
              for (int i = 0; i  < numGroups; i++) {
                  visit(groups[i], level + 1);
               }
          }

       

      }

       

      /* ------------------------------ cut  & paste  ------------------------------------------------------------ */

       

      /*  *******************  CONSOLE OUTPUT *************************** */

       

      --------  Synchronous call
      1.- normal call
      -------- Asynchronous call
      Direct return of async invocation is: null
      -------- Synchronous call
      3.-  normal call 2
      -------- Result of Asynchronous call
      Waiting for  asynbch invocation to complete
      true
      ->2.- asynchronous call  test Thu Jun 24 16:55:30 GMT+01:00 2010
      FIN
      0 Thread[Reference Handler,10,system]
      0  Thread[Finalizer,8,system]
      0 Thread[Signal Dispatcher,9,system]
      0  Thread[Attach Listener,5,system]
      0 Thread[RMI RenewClean-[127.0.0.1:1098],5,system]
      0 Thread[GC Daemon,2,system]
      0 Thread[RMI Scheduler(0),5,system]
      1  Thread[main,5,main]
      1 Thread[pool-1-thread-1,5,main]

      AsyncUtils.mixinAsync  future lock for a minute