快捷導(dǎo)航

SpringBoot中使用@Async注解失效場景及說明

更新時(shí)間：2024年07月24日 09:36:28 作者：安騰斯科技

在Spring?Boot中,@Async注解就像一把刀,能幫你輕松處理那些耗時(shí)的任務(wù),讓主線程可以繼續(xù)忙別的事兒,不過,跟所有強(qiáng)大的工具一樣,用不好它也可能出岔子,為了避免這些坑,咱們得深入了解下@Async注解,接下來,咱們就來聊聊7種常見的@Async失效情況,需要的朋友可以參考下

場景一：調(diào)用者與被調(diào)用者在同一個(gè)類中
場景二：配置類未啟用異步支持
場景三：方法不是 public 的
場景四：線程池未正確配置
場景五：異常處理不當(dāng)
場景六：Spring代理未生效
場景七：使用 @Transactional 與 @Async 同時(shí)注解方法，導(dǎo)致事務(wù)失效
總結(jié)一下：

場景一：調(diào)用者與被調(diào)用者在同一個(gè)類中

當(dāng)調(diào)用 @Async 注解的方法的類和被調(diào)用的方法在同一個(gè)類中時(shí)，@Async 注解不會(huì)生效。因?yàn)?Spring 的 AOP 代理是基于接口的，對于同一個(gè)類中的方法調(diào)用，不會(huì)經(jīng)過代理，因此 @Async 注解不會(huì)被處理。

例如：

@Service  
public class MyService {  
  
    @Async  
    public void asyncMethod() {  
        // 模擬耗時(shí)操作  
        try {  
            System.out.println("開始異步執(zhí)行");  
            Thread.sleep(5000);  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        }  
        System.out.println("Async method executed.");  
    }  
  
    public void callAsyncMethod() {  
        asyncMethod(); // 直接調(diào)用，不會(huì)異步執(zhí)行  
    }  
}

場景二：配置類未啟用異步支持

如果配置類中沒有啟用異步支持，即沒有使用 @EnableAsync 注解，那么 @Async 注解同樣不會(huì)生效。

例如：

// 沒有使用 @EnableAsync 注解，因此不會(huì)啟用異步支持  
@Configuration  
public class AsyncConfig {  
    // ... 其他配置 ...  
}  
  
@Service  
public class MyService {  
  
    @Async  
    public void asyncMethod() {  
        // 模擬耗時(shí)操作  
        try {  
            Thread.sleep(5000);  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        }  
        System.out.println("Async method executed.");  
    }  
}

場景三：方法不是 public 的

@Async 注解的方法必須是 public 的，否則不會(huì)被 Spring AOP 代理捕獲，導(dǎo)致異步執(zhí)行不生效。

例如：

@Service  
public class MyService {  
  
    @Async // 但這個(gè)方法不是 public 的，所以 @Async 不會(huì)生效  
    protected void asyncMethod() {  
        // 模擬耗時(shí)操作  
        try {  
            Thread.sleep(5000);  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        }  
        System.out.println("Async method executed.");  
    }  
  
    public void callAsyncMethod() {  
        asyncMethod(); // 直接調(diào)用，但由于 asyncMethod 不是 public 的，因此不會(huì)異步執(zhí)行  
    }  
}

場景四：線程池未正確配置

在使用 @Async 注解時(shí)，如果沒有正確配置線程池，可能會(huì)遇到異步任務(wù)沒有按預(yù)期執(zhí)行的情況。例如，線程池被配置為只有一個(gè)線程，且該線程一直被占用，那么新的異步任務(wù)就無法執(zhí)行。

例如：

@Configuration  
@EnableAsync  
public class AsyncConfig implements AsyncConfigurer {  
  
    @Override  
    public Executor getAsyncExecutor() {  
        // 創(chuàng)建一個(gè)只有一個(gè)線程的線程池，這會(huì)導(dǎo)致并發(fā)問題  
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();  
        executor.setCorePoolSize(1);  
        executor.setMaxPoolSize(1);  
        executor.setQueueCapacity(10);  
        executor.setThreadNamePrefix("Async-");  
        executor.initialize();  
        return executor;  
    }  
  
    // ... 其他配置 ...  
}
  
@Service  
public class MyService {  
  
    @Async  
    public void asyncMethod() {  
        // 模擬耗時(shí)操作  
        try {  
            Thread.sleep(5000);  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        }  
        System.out.println("Async method executed.");  
    }  
}

場景五：異常處理不當(dāng)

如果在異步方法中拋出了異常，并且沒有妥善處理，那么這個(gè)異?？赡軙?huì)導(dǎo)致任務(wù)失敗，而調(diào)用者可能無法感知到異常的發(fā)生。

例如：

@Service  
public class MyService {  
  
    @Async  
    public void asyncMethod() {  
        // 模擬一個(gè)可能會(huì)拋出異常的耗時(shí)操作  
        throw new RuntimeException("Async method exception");  
    }  
}
// 調(diào)用者  
@Service  
public class CallerService {  
  
    @Autowired  
    private MyService myService;  
  
    public void callAsyncMethod() {  
        myService.asyncMethod(); // 調(diào)用異步方法，但如果該方法拋出異常，調(diào)用者不會(huì)立即感知到  
    }  
}

場景六：Spring代理未生效

如果通過 new 關(guān)鍵字直接創(chuàng)建了服務(wù)類的實(shí)例，而不是通過 Spring 容器來獲取，那么 Spring 的 AOP 代理將不會(huì)生效，導(dǎo)致 @Async 注解無效。

例如：

@Service  
public class MyService {  
  
    @Async  
    public void asyncMethod() {  
        // 模擬耗時(shí)操作  
        try {  
            Thread.sleep(5000);  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        }  
        System.out.println("Async method executed.");  
    }  
}  
  
public class SomeNonSpringClass {  
  
    public void someMethod() {  
        MyService myService = new MyService(); // 直接通過 new 創(chuàng)建 MyService 實(shí)例，不會(huì)經(jīng)過 Spring 代理  
        myService.asyncMethod(); // 這里 @Async 不會(huì)生效  
    }  
}

場景七：使用 @Transactional 與 @Async 同時(shí)注解方法，導(dǎo)致事務(wù)失效

在同一個(gè)方法上同時(shí)使用 @Transactional 和 @Async 注解可能會(huì)導(dǎo)致問題。由于 @Async 會(huì)導(dǎo)致方法在一個(gè)新的線程中執(zhí)行，而 @Transactional 通常需要在一個(gè)由 Spring 管理的事務(wù)代理中執(zhí)行，這兩個(gè)注解的結(jié)合使用可能會(huì)導(dǎo)致事務(wù)管理失效或行為不可預(yù)測。此種場景不會(huì)導(dǎo)致@Async注解失效，但是會(huì)導(dǎo)致@Transactional注解失效，也就是事務(wù)失效。

例如：

@Service  
public class MyService {  
  
    @Autowired  
    private MyRepository myRepository;  
  
    // 錯(cuò)誤的用法：同時(shí)使用了 @Transactional 和 @Async  
    @Transactional  
    @Async  
    public void asyncTransactionalMethod() {  
        // 模擬一個(gè)數(shù)據(jù)庫操作  
        myRepository.save(new MyEntity());  
          
        // 模擬可能拋出異常的代碼  
        if (true) {  
            throw new RuntimeException("Database operation failed!");  
        }  
    }  
}  
  
@Repository  
public interface MyRepository extends JpaRepository<MyEntity, Long> {  
    // ...  
}  
  
@Entity  
public class MyEntity {  
    // ... 實(shí)體類的屬性和映射 ...  
}

總結(jié)一下：

絕大多數(shù)人會(huì)遇到的坑點(diǎn)主要會(huì)集中在沒有配置自定義線程池、異步方法在同一個(gè)類中調(diào)用、事務(wù)不起作用這幾個(gè)問題上。所以，萬金油的寫法還是專門定義一個(gè)AsyncService，將異步方法都寫在里面，需要使用的時(shí)候，就在其他類將其注入即可。

以上就是SpringBoot中使用@Async注解失效場景及說明的詳細(xì)內(nèi)容，更多關(guān)于SpringBoot @Async注解失效的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: