EJB Eşzamansız yöntemlerini kullanmanın doğru yolu

Question

Yapmam gereken iki görevi var aynı iş sürecinin bir parçası olan task1 ve task2. Son kullanıcıya, task1 tamamlandığında yanıt vermem gerekiyor, böylece yanıt süresinin en aza indirilmesi gerekiyor.

Şu anki yaklaşımım task1 gerçekleştirmek ve task1 bittiğinde, zaman uyumsuz olarak task2 yöntemini çağırmaktır. task2 karmaşık ve bazı dış bağımlılık olduğu için yanıt süresi kontrolüm dışında. websphere 8.0 (kullanımda EJB konteyner) eşzamanlı yöntemler ve asenkron yöntemlerde

@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 
    } 

} 

farklı diş havuzları tarafından işletilmektedir.

Benim ilk varsayımın, task2'un kötü performans göstermesi durumunda bile task1'un bir etkisi olmayacağı, ancak ne yazık ki bu doğru olmadığıydı.

task2 hatalı çalışıyorsa, zaman uyumsuz iş parçacığı havuzundaki tüm iş parçacıkları dolu olacaktır. Bu, asenkron ipliklerin serbest olmasını ve dolayısıyla task1'un etkisi olmasını beklemek için task1 neden olur.

websphrere sunucu günlüklerinde mesajı: The request buffer for thread pool WorkManager.WebSphere_EJB_Container_AsynchMethods_Internal_WorkManager has reached its capacity

Sorum Burada elde etmek çalışıyorum ulaşmak için uygun bir yol olacağını budur.

Answer 1

aramanız gerekmektedir olarak inşallah

Bu kullanım örneğini uygun Yönetici Konsolu'nda "EJB eşzamansız yöntem çağırma ayarları" nın boyutu. Bu, asıl iş parçacığı havuzundan önce bir sıra, bu yüzden size biraz daha zaman kazandırabilir.

İdeal olarak bu, yukarıda önerilen zaman aşımları ile birlikte kullanılmalıdır.

Answer 2

Sanırım @AccessTimeout sizin için. Bir örnek görüyorum here Bu, .doTask2() 'nın çalışıp sorununuzu önleyebileceği süreyi sınırlayacaktır.

@Stateless 
public class SessionBean1 { 

    @Inject 
    SessionBean2 sessionBean2; 

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

} 

SessionBean2

alternatif olarak

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

} 

:

handle.get kullanımı, uyumsuz işlem sunar süresini sınırlamak için (xx TimeUnit.xx); yöntem. Ayrıca, Gelecek'i iade etmeniz ve sadece işe yaraması için geçersiz olmanız gerekmeyecektir. Başka bir alternatif "Work istek sırasını artırmak olacağını bir .get

@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); 
    } 

}