¿Algún buen hilo de resorte con ejemplos de TaskExecutor?

Question

Estoy tratando de entender cómo implementar el subproceso en una aplicación Java que utiliza Spring para la administración de transacciones. Encontré la sección TaskExecutor en el Spring documentation, y ThreadPoolTaskExecutor parece que se ajusta a mis necesidades;

ThreadPoolTaskExecutor

Esta aplicación sólo se puede utilizar en un entorno Java 5, pero también es el más comúnmente utilizado uno en ese entorno. Expone propiedades de beans para configurar un java.util.concurrent.ThreadPoolExecutor y lo envuelve en un TaskExecutor. Si necesita algo avanzado, como un ScheduledThreadPoolExecutor, se recomienda utilizar un ConcurrentTaskExecutor.

Sin embargo, no tengo ni idea de cómo usarlo. He estado buscando buenos ejemplos por un tiempo sin suerte. Si alguien puede ayudarme, lo agradecería.

Answer 1

Es bastante simple. La idea es que tienes un objeto ejecutor que es un bean, que se pasa al objeto que quiera disparar la nueva tarea (en un nuevo hilo). Lo bueno es que puedes modificar qué tipo de ejecutor de tareas usar simplemente cambiando las configuraciones de Spring. En el siguiente ejemplo, tomo una clase de ejemplo (ClassWithMethodToFire) y la envuelvo en un objeto Runnable para activar el fuego; también podría implementar Runnable en una clase propia, y luego en el método de ejecución simplemente llamaría al classWithMethodToFire.run().

Aquí hay un ejemplo muy simple.

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

Y aquí están los granos de primavera:

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