13

根据Spring 的文档，使用 TaskExecutor 的方式如下：

import org.springframework.core.task.TaskExecutor;

public class TaskExecutorExample {

  private class MessagePrinterTask implements Runnable {

    private String message;

    public MessagePrinterTask(String message) {
      this.message = message;
    }

    public void run() {
      System.out.println(message);
    }

  }

  private TaskExecutor taskExecutor;

  public TaskExecutorExample(TaskExecutor taskExecutor) {
    this.taskExecutor = taskExecutor;
  }

  public void printMessages() {
    for(int i = 0; i < 25; i++) {
      taskExecutor.execute(new MessagePrinterTask("Message" + i));
    }
  }
}

但是，如果 MessagePrinterTask 具有自动装配的依赖关系，它们将不会由 Spring 配置，因为我们在 Spring 的上下文之外实例化我们的 bean（至少我是这样理解的），即使 Spring 将提供实际的线程创建。如果 MessagePrinterTask 具有自动装配的依赖关系，我们如何让 Spring 识别它们？我尝试了以下修改后的示例无济于事（是的，自动装配已正确启用）：

import org.springframework.core.task.TaskExecutor;

public class TaskExecutorExample {

  @Component
  private class MessagePrinterTask implements Runnable {

    @Autowired
    private autoWiredDependency;

    public void run() {
      autoWiredDependency.doNotThrowNullPointerExceptionPlease();
    }

  }

  private TaskExecutor taskExecutor;

  public TaskExecutorExample(TaskExecutor taskExecutor) {
    this.taskExecutor = taskExecutor;
  }

  public void printMessages() {
    for(int i = 0; i < 25; i++) {
      taskExecutor.execute(new MessagePrinterTask());
    }
  }
}
4

3 回答 3

16

我认为有两种方法可以解决这个问题：

一个。为任务提供依赖项 - 这样：

class MessagePrinterTask implements Runnable {
    public MessagePrinterTask(ADependency aDependency){
        this.aDependency = aDependency;
    }


    private ADependency aDependency;

    public void run() {
        aDependency.doNotThrowNullPointerExceptionPlease();
    }
}

在您的 TaskExectorExample 中，它可以是单例：

import org.springframework.core.task.TaskExecutor;

public class TaskExecutorExample {

  @Autowired  private ADependency aDependency;

  @Autowired
  public TaskExecutorExample(TaskExecutor taskExecutor) {
    this.taskExecutor = taskExecutor;
  }

  public void printMessages() {
    for(int i = 0; i < 25; i++) {
      taskExecutor.execute(new MessagePrinterTask(this.aDependency));
    }
  }
}

湾。在 MesasgePrinterTask 上使用 @Configurable 注释，这会将依赖项注入到 MessagePrinterTask 中，即使它是在 Spring 容器之外实例化的——尽管使用 @Configurable 有一些问题（需要 AspectJ）：

@Configurable
class MessagePrinterTask implements Runnable {
于 2012-08-03T00:06:43.363 回答
3

您还可以使用 @Async 注释。

public class TaskExecutorExample {

    @Autowired
    private MessagePrinterTask task;

    public void printMessages() {
        for(int i = 0; i < 25; i++) {
            task.printMessage();
        }
    }
}

@Component
public class MessagePrinterTask implements Runnable {

    @Autowired
    private String message;

    @Async
    public void printMessage() {
      System.out.println(message);
    }

}

任何对 printMessage() 的调用都将使用默认执行程序异步执行，您可以在 Spring xml 配置中使用以下内容进行配置。

<task:annotation-driven executor="myExecutor"/>
<task:executor id="myExecutor" pool-size="5" />
于 2013-07-19T10:50:34.293 回答
0

试试这个方法。

@Service
@Scope("prototype")
public invokeClass {

    @Autowired
    private ApplicationContext applicationContext;



    public void methodName(TestRequest input){
        TaskExecutor taskExecutor = new SimpleAsyncTaskExecutor();

        taskExecutor.execute(new Runnable() {
            public void run() {

                applicationContext.getBean("testService", TestService.class).execute(input);
            }
        });
    }
}
于 2019-01-09T01:45:00.390 回答