"  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