异步async

### JavaScript 中 `async` 和 `await` 的基本用法 在现代编程语言中，异步操作是一种常见的需求。JavaScript 提供了 `async` 和 `await` 关键字来简化异步代码的编写和维护。以下是关于如何使用它们的一个简单介绍以及示例。 #### 定义 `async` 函数 当定义一个函数时，在其前面加上 `async` 关键字，则该函数会返回一个 Promise 对象[^1]。即使函数内部没有显式的 `return` 语句，默认也会返回一个已解析的 Promise。 ```javascript // 定义一个简单的 async 函数 async function fetchData() { return "Data fetched successfully"; } fetchData().then(data => console.log(data)); // 输出: Data fetched successfully ``` #### 使用 `await` 处理异步操作 `await` 只能在 `async` 函数内部使用，用于等待一个 Promise 解析完成后再继续执行后续代码[^1]。这使得异步代码看起来像同步代码一样直观易读。 ```javascript // 模拟一个耗时的操作 function delay(ms) { return new Promise(resolve => setTimeout(resolve, ms)); } async function exampleAwait() { console.log("Start"); await delay(1000); // 等待 1 秒钟 console.log("End after 1 second"); } exampleAwait(); ``` #### 错误处理 通过 `try...catch` 结构可以优雅地捕获并处理异步操作中的错误[^1]。 ```javascript async function fetchUserData(id) { try { const response = await fetch(`https://api.example.com/users/${id}`); if (!response.ok) throw new Error('Network response was not ok'); const data = await response.json(); return data; } catch (error) { console.error('There was a problem with the fetch operation:', error); } } ``` --- ### Rust 中 `async` 和 `.await` 的实现方式 Rust 是一种系统级编程语言，也支持异步编程模型。为了使异步代码能够正常工作，通常需要引入诸如 Tokio 这样的运行时环境[^2]。 #### 创建异步任务 在 Rust 中声明一个异步函数需要用到 `async` 关键字，并且可以通过 `.await` 来暂停当前任务直到另一个异步操作完成。 ```rust use std::time::Duration; #[tokio::main] async fn main() { let result = do_something_async().await; println!("Async operation result: {}", result); } async fn do_something_async() -> i32 { tokio::time::sleep(Duration::from_secs(1)).await; // 等待 1 秒 42 // 返回结果 } ``` 此代码片段展示了如何利用 Tokio 库创建一个异步主线程，并调用其他异步函数以模拟延迟计算的结果[^2]。 --- ### Spring Boot 中基于 @Async 注解的异步方法 Java 开发者也可以借助框架功能轻松管理异步逻辑。Spring Boot 支持通过 `@Async` 注解标记的方法自动开启新线程去执行指定的任务[^3]。 #### 配置线程池 默认情况下，`@Async` 方法会在单独的线程中运行，但如果希望自定义行为则需调整 ThreadPoolTaskExecutor 设置： ```java import org.springframework.context.annotation.Bean; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import java.util.concurrent.Executor; @Configuration public class AsyncConfig { @Bean(name = "taskExecutor") public Executor taskExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); executor.setCorePoolSize(5); // 核心线程数 executor.setMaxPoolSize(10); // 最大线程数 executor.setQueueCapacity(25); // 阻塞队列容量 executor.initialize(); return executor; } } ``` #### 实现异步服务 一旦配置好线程池之后就可以安全地标注任何业务层的服务类或者方法为异步模式： ```java @Service public class MyService { @Async("taskExecutor") // 显式指定了使用的线程池名称 public void performAsyncOperation(String message) throws InterruptedException { System.out.println(Thread.currentThread().getName() + ": Starting process..."); Thread.sleep(2000L); // Simulate long-running job. System.out.println(message); } } ``` 以上例子说明了 Java 如何结合注解与配置文件共同作用从而达到高效并发控制的目的[^3]。 ---