mfc 彈簧

以前，我們開始使用spring和TaskExecutor ，因此我們對如何在spring應用程序中使用線程更加熟悉。

但是，使用任務執行程序可能比較麻煩，尤其是當我們需要執行簡單的操作時。

Spring的異步方法可以解決。

您不必為可運行對象和TaskExecutor煩惱，而是為了簡化異步功能而對執行程序的控制權進行了交易。
為了在另一個線程中執行函數，您要做的就是使用@Async注釋對函數進行注釋。

異步方法有兩種模式。

一勞永逸模式：一種返回void類型的方法。

@Async@Transactionalpublic void printEmployees() {List<Employee> employees = entityManager.createQuery("SELECT e FROM Employee e").getResultList();employees.stream().forEach(e->System.out.println(e.getEmail()));}

結果檢索模式：一種返回未來類型的方法。

@Async@Transactionalpublic CompletableFuture<List<Employee>> fetchEmployess() {List<Employee> employees = entityManager.createQuery("SELECT e FROM Employee e").getResultList();return CompletableFuture.completedFuture(employees);}

要特別注意以下事實：@Async注釋如果被'this'調用，則不起作用。 @Async的行為就像@Transactional批注一樣。 因此，您需要將異步功能公開。 您可以在aop代理文檔中找到更多信息。

但是，僅使用@Async注釋是不夠的。 我們需要通過在我們的配置類之一中使用@EnableAsync注釋來啟用Spring的異步方法執行功能。

package com.gkatzioura.config;import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.core.task.TaskExecutor; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;import java.util.concurrent.Executor;/*** Created by gkatzioura on 4/26/17.*/ @Configuration @EnableAsync public class ThreadConfig {@Beanpublic TaskExecutor threadPoolTaskExecutor() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(4);executor.setMaxPoolSize(4);executor.setThreadNamePrefix("sgfgd");executor.initialize();return executor;}}

下一個問題是我們如何聲明異步函數將使用的資源和線程池。 我們可以從文檔中得到答案。

默認情況下，Spring將搜索關聯的線程池定義：上下文中的唯一TaskExecutor bean，否則為名為“ taskExecutor”的Executor bean。 如果二者都不可解決，則將使用SimpleAsyncTaskExecutor處理異步方法調用。

但是在某些情況下，我們不希望同一線程池運行應用程序的所有任務。 我們可能希望具有不同配置的單獨線程池支持我們的功能。

為此，我們將可能要用于每個函數的執行程序的名稱傳遞給@Async批注。

例如，配置了名稱為“ specificTaskExecutor”的執行程序。

@Configuration @EnableAsync public class ThreadConfig {@Bean(name = "specificTaskExecutor")public TaskExecutor specificTaskExecutor() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.initialize();return executor;}}

然后，我們的函數應設置限定符值，以確定特定執行程序或TaskExecutor的目標執行程序。

@Async("specificTaskExecutor") public void runFromAnotherThreadPool() {System.out.println("You function code here"); }

下一篇文章我們將討論線程事務。

您可以在github上找到源代碼。

翻譯自: https://www.javacodegeeks.com/2017/10/spring-threads-async.html

mfc 彈簧

總結

以上是生活随笔為你收集整理的mfc 弹簧_弹簧和线程：异步的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。