使用EJB的正确方法异步方法

Question

我有两个任务需要执行，分别是task1和task2，它们是相同业务流程的一部分。当task1完成时，我必须对最终用户做出响应，因此它的响应时间必须最小化。

我目前的做法是执行task1，只要task1完成，就异步调用task2方法。 task2是复杂的，它的响应时间超出了我的控制范围，因为它具有一些外部依赖性。

@Stateless 
public class SessionBean1 { 

    @Inject 
    SessionBean2 sessionBean2; 

    public void doTask1(){ 
     // task one stuff 
     sessionBean2.doTask2(); 
    } 

} 



@Stateless 
public class SessionBean2 { 

    @Asynchronous 
    public void doTask2(){ 
     // do task2 stuff 
    } 

} 

在websphere 8.0（所使用的EJB容器）中，同步方法和异步方法由不同的线程池运行。

我的初步假设是，即使task2表现不佳，task1也没有影响，但可悲的是，事实并非如此。

如果task2执行得不好，异步线程池中的所有线程都将被占用。这将导致task1等待异步线程空闲，因此task1会产生影响。

在websphrere服务器日志的消息： The request buffer for thread pool WorkManager.WebSphere_EJB_Container_AsynchMethods_Internal_WorkManager has reached its capacity

我的问题是，这将是实现我想要在这里实现有道。

Answer 1

另一种方法是增加“工作请求队列管理控制台中“EJB异步方法调用设置”的大小。这是一个队列，在实际的线程池本身之前，所以这可能会给你多一点时间。

理想情况下，这应该与上面提到的超时结合使用。

Answer 2

我认为@AccessTimeout是你在找什么。我看到一个示例here 这将限制.doTask2（）可以运行的时间并避免您的问题。

@Stateless 
public class SessionBean1 { 

    @Inject 
    SessionBean2 sessionBean2; 

    public void doTask1(){ 
     // task one stuff 
     sessionBean2.doTask2(); 
    } 

} 

SessionBean2

@Stateless 
public class SessionBean2 { 
    @AccessTimeout(60000)//default timeunit is TimeUnit.MILLISECONDS 
    @Asynchronous 
    public void doTask2(){ 
     // do task2 stuff 
    } 

} 

作为替代：

为了限制时的异步过程可能需要，使用handle.get（XX，TimeUnit.xx ）;方法。您还需要返回Future，而不是仅仅使其失效。

我希望这适合您的使用情况下，您将需要调用。获得

@Stateless 
public class SessionBean1 { 

    @Inject 
    SessionBean2 sessionBean2; 

    public void doTask1(){ 
     // task one stuff 
     Future<Void> handle = sessionBean2.doTask2(); 
     // do other stuff 
     handle.get(10, TimeUnit.SECONDS);//If you want to block later 

    } 

} 

SessionBean2

@Stateless 
public class SessionBean2 { 

    @Asynchronous 
    public Future<Void> doTask2(){ 
     // do task2 stuff 
     new AsyncResult<Void>(Void); 
    } 

}