1 /* 2 * JBoss, Home of Professional Open Source 3 * Copyright 2005, JBoss Inc., and individual contributors as indicated 4 * by the @authors tag. See the copyright.txt in the distribution for a 5 * full listing of individual contributors. 6 * 7 * This is free software; you can redistribute it and/or modify it 8 * under the terms of the GNU Lesser General Public License as 9 * published by the Free Software Foundation; either version 2.1 of 10 * the License, or (at your option) any later version. 11 * 12 * This software is distributed in the hope that it will be useful, 13 * but WITHOUT ANY WARRANTY; without even the implied warranty of 14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 15 * Lesser General Public License for more details. 16 * 17 * You should have received a copy of the GNU Lesser General Public 18 * License along with this software; if not, write to the Free 19 * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 20 * 02110-1301 USA, or see the FSF site: http://www.fsf.org. 21 */ 22 package org.jboss.aspects.asynch; 23 24 import java.util.concurrent.Callable; 25 import java.util.concurrent.ExecutorService; 26 import java.util.concurrent.Executors; 27 28 import org.jboss.aop.Advisor; 29 import org.jboss.aop.joinpoint.MethodInvocation; 30 31 /** 32 * Comment 33 * 34 * @author <a HREF="mailto:bill@jboss.org">Bill Burke</a> 35 * @version $Revision: 57757 $ 36 */ 37 public class ThreadPoolExecutor implements ExecutorAbstraction 38 { 39 private static ExecutorService executor = Executors.newCachedThreadPool(); 40 41 public void setAdvisor(Advisor advisor) 42 { 43 44 } 45 46 public RemotableFuture execute(MethodInvocation invocation) throws Exception 47 { 48 final MethodInvocation copy = (MethodInvocation) invocation.copy(); 49 final ClassLoader cl = Thread.currentThread().getContextClassLoader(); 50 51 java.util.concurrent.Future future = executor.submit(new Callable() 52 { 53 public Object call() throws Exception 54 { 55 try 56 { 57 Thread.currentThread().setContextClassLoader(cl); 58 return copy.invokeNext(); 59 } 60 catch (Throwable throwable) 61 { 62 if (throwable instanceof Exception) 63 { 64 throw ((Exception) throwable); 65 } 66 else 67 throw new Exception(throwable); 68 } 69 } 70 }); 71 72 return new FutureImplJavaUtilConcurrent(future); 73 } 74 75 } 76