使用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); 
    } 

}