1 22 package org.jboss.test.cts.test; 23 24 import org.jboss.test.cts.interfaces.StrictlyPooledSession; 25 import org.jboss.test.cts.interfaces.StrictlyPooledSessionHome; 26 27 import org.jboss.logging.Logger; 28 import EDU.oswego.cs.dl.util.concurrent.CountDown; 29 30 34 public class SessionInvoker extends Thread 35 { 36 StrictlyPooledSessionHome home; 37 Logger log; 38 int id; 39 CountDown done; 40 Exception runEx; 41 public SessionInvoker(StrictlyPooledSessionHome home, int id, CountDown done, 42 Logger log) 43 { 44 super("SessionInvoker#"+id); 45 this.home = home; 46 this.id = id; 47 this.done = done; 48 this.log = log; 49 } 50 public void run() 51 { 52 log.debug("Begin run, this="+this); 53 try 54 { 55 StrictlyPooledSession session = home.create(); 56 session.methodA(); 57 session.remove(); 58 } 59 catch(Exception e) 60 { 61 runEx = e; 62 } 63 done.release(); 64 log.debug("End run, this="+this); 65 } 66 67 } 68 | Popular Tags |