快捷導(dǎo)航

SpringBoot中使用@Async注解失效場(chǎng)景及說(shuō)明

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

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

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

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

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

例如：

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

場(chǎng)景二：配置類(lèi)未啟用異步支持

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

例如：

// 沒(méi)有使用 @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.");  
    }  
}

場(chǎng)景三：方法不是 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í)行  
    }  
}

場(chǎng)景四：線程池未正確配置

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

例如：

@Configuration  
@EnableAsync  
public class AsyncConfig implements AsyncConfigurer {  
  
    @Override  
    public Executor getAsyncExecutor() {  
        // 創(chuàng)建一個(gè)只有一個(gè)線程的線程池，這會(huì)導(dǎo)致并發(fā)問(wèn)題  
        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.");  
    }  
}

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

如果在異步方法中拋出了異常，并且沒(méi)有妥善處理，那么這個(gè)異常可能會(huì)導(dǎo)致任務(wù)失敗，而調(diào)用者可能無(wú)法感知到異常的發(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ì)立即感知到  
    }  
}

場(chǎng)景六：Spring代理未生效

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

例如：

@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(); // 直接通過(guò) new 創(chuàng)建 MyService 實(shí)例，不會(huì)經(jīng)過(guò) Spring 代理  
        myService.asyncMethod(); // 這里 @Async 不會(huì)生效  
    }  
}

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

在同一個(gè)方法上同時(shí)使用 @Transactional 和 @Async 注解可能會(huì)導(dǎo)致問(wèn)題。由于 @Async 會(huì)導(dǎo)致方法在一個(gè)新的線程中執(zhí)行，而 @Transactional 通常需要在一個(gè)由 Spring 管理的事務(wù)代理中執(zhí)行，這兩個(gè)注解的結(jié)合使用可能會(huì)導(dǎo)致事務(wù)管理失效或行為不可預(yù)測(cè)。此種場(chǎng)景不會(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ù)庫(kù)操作  
        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í)體類(lèi)的屬性和映射 ...  
}

總結(jié)一下：

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

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

您可能感興趣的文章: