草庐IT

taskExecutor

全部标签

java - 将 FlatFileItemReader 与 TaskExecutor 一起使用(线程安全)

有很多使用FlatFileItemReader和TaskExecutor的例子。我在下面提供示例(包括XML和Java配置):UsingOracleCoherencewithSpringBatchSpringBatchMultithreadingExample我自己将它与XML配置一起使用,用于使用开箱即用的JpaItemWriter写入数据库的大型CSV(GB大小)。即使不设置save-state=false或采取任何特殊处理,似乎也没有问题。现在,FlatFileItemReader被记录为不是线程安全的。我的猜测是JpaItemWriter通过持久化Sets来“覆盖”这个问题,即

java - 为什么 Autowiring 在线程中不起作用?

我在Spring3.0中创建了一个maven项目,我创建了一些DAO、服务和Controller,在我的一个Controller中我调用了一个服务,在该服务中我启动了一个线程,问题是在我声明的线程中应该使用Autowiring注解初始化的“服务变量”,但它不起作用并且变量未初始化且值为null。这是线程类packagecom.project.tasks;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.core.task.TaskExecutor;importor

java - 您可以将 Future/Futuretask 对象与 Spring TaskExecutors 一起使用吗?

是否可以使用JavaFutureTask使用SpringTaskExecutor获得Future目的?我正在寻找实现JavaExecutorService的TaskExecutor接口(interface),特别是submit()方法。翻看SpringJavadocs不会透露任何这样的类(class)。是否有一些我不知道的通过SpringTaskExecutors处理future的替代方法?如果可能的话,您能否也提供一个示例? 最佳答案 Spring3已将支持Future对象的提交方法添加到AsyncTaskExecutor.在那之

java - Spring 的多线程

我正在尝试进入spring多线程,我有几个问题。我在ThreadRating类中有可运行的方法。现在我不确定使用它的最佳方式。我找到的选项1:privatevoidupdateRating(){ExecutorServiceexecutor=Executors.newFixedThreadPool(10);for(inti=0;i这似乎运行良好。for循环后,等待线程执行完毕结束。我尝试的第二个选项privateTaskExecutortaskExecutor;publicUpdateBO(TaskExecutortaskExecutor){this.taskExecutor=task

java - Spring 3 : How to call @Async annotated methods from the TaskExecutor

我是Spring中异步任务执行的新手,所以如果这听起来像一个愚蠢的问题,请原谅我。我读到@Async注释是从Spring3.x开始在方法级别引入的,该方法的调用将异步发生。我还读到我们可以在spring配置文件中配置ThreadPoolTask​​Executor。我无法理解的是,假设如何从tak执行器调用@Async带注释的方法-AsyncTaskExecutor之前我们经常在类里面做类似的事情:@AutowiredprotectedAsyncTaskExecutorexecutor;然后executor.submit()我无法理解@Async注解的方法和TaskExecutor之间

java - Spring 3 : How to call @Async annotated methods from the TaskExecutor

我是Spring中异步任务执行的新手,所以如果这听起来像一个愚蠢的问题,请原谅我。我读到@Async注释是从Spring3.x开始在方法级别引入的,该方法的调用将异步发生。我还读到我们可以在spring配置文件中配置ThreadPoolTask​​Executor。我无法理解的是,假设如何从tak执行器调用@Async带注释的方法-AsyncTaskExecutor之前我们经常在类里面做类似的事情:@AutowiredprotectedAsyncTaskExecutorexecutor;然后executor.submit()我无法理解@Async注解的方法和TaskExecutor之间

java - 如何 Autowiring Spring TaskExecutor 创建的线程?

根据Spring'sdocumentationTaskExecutor的使用方法如下:importorg.springframework.core.task.TaskExecutor;publicclassTaskExecutorExample{privateclassMessagePrinterTaskimplementsRunnable{privateStringmessage;publicMessagePrinterTask(Stringmessage){this.message=message;}publicvoidrun(){System.out.println(messag

java - 如何 Autowiring Spring TaskExecutor 创建的线程?

根据Spring'sdocumentationTaskExecutor的使用方法如下:importorg.springframework.core.task.TaskExecutor;publicclassTaskExecutorExample{privateclassMessagePrinterTaskimplementsRunnable{privateStringmessage;publicMessagePrinterTask(Stringmessage){this.message=message;}publicvoidrun(){System.out.println(messag

java - Spring Boot 。如何创建带注解的 TaskExecutor?

我在SpringBoot应用程序中做了一个@Service类,其中一种方法应该异步运行。当我读到方法应该是@Async注释并且我必须运行一个TaskExecutorbean。但在Spring手册http://docs.spring.io/spring/docs/current/spring-framework-reference/html/scheduling.html我没有找到任何信息或示例如何在没有XML配置的情况下运行带有注释的TaskExecutor。是否可以在没有XML的SpringBoot中创建TaskExecutorbean,仅使用注释?这是我的服务类:@Servicep

java - Spring Boot 。如何创建带注解的 TaskExecutor?

我在SpringBoot应用程序中做了一个@Service类,其中一种方法应该异步运行。当我读到方法应该是@Async注释并且我必须运行一个TaskExecutorbean。但在Spring手册http://docs.spring.io/spring/docs/current/spring-framework-reference/html/scheduling.html我没有找到任何信息或示例如何在没有XML配置的情况下运行带有注释的TaskExecutor。是否可以在没有XML的SpringBoot中创建TaskExecutorbean,仅使用注释?这是我的服务类:@Servicep
12