Cách đúng để sử dụng các phương pháp không đồng bộ EJB

Question

Tôi có hai tác vụ mà tôi cần thực hiện nói task1 và task2 là một phần của cùng một quy trình nghiệp vụ. Tôi phải trả lời cho người dùng cuối khi hoàn thành task1 để thời gian đáp ứng của nó phải được giảm thiểu.

Cách tiếp cận hiện tại của tôi là thực hiện task1 và ngay sau khi task1 kết thúc, hãy gọi phương thức task2 không đồng bộ. task2 phức tạp và thời gian phản hồi nằm ngoài tầm kiểm soát của tôi vì nó có một số phụ thuộc bên ngoài.

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

} 

Trong websphere 8.0 (EJB container đang sử dụng) phương pháp đồng bộ và phương pháp không đồng bộ được điều hành bởi các nhóm luồng khác nhau.

Giả định ban đầu của tôi là ngay cả khi task2 đang hoạt động kém, task1 sẽ không có tác động, nhưng đáng buồn là điều đó không đúng.

Nếu task2 đang hoạt động kém, tất cả các chuỗi từ nhóm chủ đề không đồng bộ sẽ bị chiếm đóng. Điều này sẽ gây ra task1 để chờ các chuỗi không đồng bộ được miễn phí và do đó task1 có tác động.

Thông điệp trong nhật ký máy chủ websphrere: The request buffer for thread pool WorkManager.WebSphere_EJB_Container_AsynchMethods_Internal_WorkManager has reached its capacity

Câu hỏi của tôi là những gì sẽ là một cách thích hợp để đạt được những gì tôi đang cố gắng để đạt được ở đây.

Answer 1

Một lựa chọn khác sẽ là tăng cường hàng đợi "Yêu cầu công việc kích thước "của" cài đặt yêu cầu phương thức không đồng bộ EJB "trong Bảng điều khiển dành cho quản trị viên. Đây là hàng đợi, trước hồ bơi chủ đề thực sự, vì vậy điều này có thể giúp bạn có thêm thời gian.

Lý tưởng nhất nên sử dụng kết hợp này với thời gian chờ được đề xuất ở trên.

Answer 2

Tôi nghĩ rằng @AccessTimeout là những gì bạn đang tìm kiếm. Tôi thấy ví dụ here Điều này sẽ giới hạn khoảng thời gian mà .doTask2() có thể chạy và tránh sự cố của bạn.

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

} 

Là một thay thế:

Để hạn chế thời gian quá trình async có thể mất, sử dụng handle.get (xx, TimeUnit.xx); phương pháp. Bạn cũng sẽ cần phải trả về Tương lai và không chỉ mất hiệu lực để làm cho nó hoạt động.

Tôi hy vọng điều này phù hợp với trường hợp sử dụng của bạn như bạn sẽ cần phải gọi một .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); 
    } 

}