Bất kỳ luồng Spring tốt nào với một ví dụ TaskExecutor?

Question

Tôi đang cố gắng để có được một xử lý về cách thực hiện luồng trong một ứng dụng Java có sử dụng Spring để quản lý giao dịch. Tôi đã tìm thấy phần TaskExecutor trong Spring documentation, và ThreadPoolTaskExecutor trông giống như nó sẽ phù hợp với nhu cầu của tôi;

ThreadPoolTaskExecutor

thi này chỉ có thể được sử dụng trong một môi trường Java 5 mà còn là một trong những phổ biến nhất được sử dụng trong môi trường đó. Nó cho thấy các thuộc tính bean để cấu hình một java.util.concurrent.ThreadPoolExecutor và kết thúc nó trong một TaskExecutor. Nếu bạn cần một cái gì đó nâng cao như một ScheduledThreadPoolExecutor, bạn nên sử dụng ConcurrentTaskExecutor thay thế.

Tuy nhiên tôi không biết cách sử dụng nó. Tôi đã tìm kiếm các ví dụ tốt cho một lúc bây giờ mà không có may mắn. Nếu bất cứ ai có thể giúp tôi, tôi sẽ đánh giá cao nó.

Answer 1

Nó khá đơn giản. Ý tưởng là bạn có một đối tượng thi hành là một bean, được truyền vào bất kỳ đối tượng nào muốn kích hoạt nhiệm vụ mới (trong một chủ đề mới). Điều thú vị là bạn có thể sửa đổi loại thực thi tác vụ nào chỉ sử dụng bằng cách thay đổi cấu hình Spring. Trong ví dụ dưới đây tôi lấy một số lớp ví dụ (ClassWithMethodToFire) và gói nó trong một đối tượng Runnable để thực hiện lửa; bạn cũng có thể thực thi Runnable trong một lớp của riêng bạn, và sau đó trong phương thức thực thi bạn chỉ cần gọi classWithMethodToFire.run().

Đây là một ví dụ rất đơn giản.

public class SomethingThatShouldHappenInAThread { 
    private TaskExecutor taskExecutor; 
    private ClassWithMethodToFire classWithMethodToFire; 

    public SomethingThatShouldHappenInAThread(TaskExecutor taskExecutor, 
               ClassWithMethodToFire classWithMethodToFire) { 
      this.taskExecutor = taskExecutor; 
      this.classWithMethodToFire = classWithMethodToFire; 
    } 

    public void fire(final SomeParameterClass parameter) { 
      taskExecutor.execute(new Runnable() { 
       public void run() { 
        classWithMethodToFire.doSomething(parameter); 
       } 
      }); 
    } 
} 

Và đây là đậu mùa xuân:

<bean name="somethingThatShouldHappenInAThread" class="package.name.SomethingThatShouldHappenInAThread"> 
    <constructor-arg type="org.springframework.core.task.TaskExecutor" ref="taskExecutor" /> 
    <constructor-arg type="package.name.ClassWithMethodToFire" ref="classWithMethodToFireBean"/> 
</bean> 

<bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"> 
    <property name="corePoolSize" value="5" /> 
    <property name="maxPoolSize" value="10" /> 
    <property name="queueCapacity" value="25" /> 
</bean>