Struct AsyncBridge

pub struct AsyncBridge;

异步/同步边界处理工具

Implementations

impl AsyncBridge

pub fn run_async_in_sync<F, T>(future: F) -> ForgeResult<T>

where F: Future<Output = ForgeResult<T>> + Send + 'static, T: Send + 'static,

在同步上下文中安全地执行异步操作

此方法会检查当前是否在 Tokio 运行时中：

• 如果在运行时中，使用 spawn_blocking 避免阻塞
• 如果不在运行时中，创建临时运行时执行

警告

此方法应该谨慎使用，主要用于：

• Drop 实现
• 同步的 FFI 边界
• 测试代码

pub fn run_async_in_sync_with_timeout<F, T>( future: F, timeout: Duration, ) -> ForgeResult<T>

where F: Future<Output = ForgeResult<T>> + Send + 'static, T: Send + 'static,

在同步上下文中安全地执行异步操作（带超时）

pub fn is_in_async_context() -> bool

检查当前是否在异步上下文中

pub async fn run_blocking_in_async<F, T>(blocking_op: F) -> ForgeResult<T>

where F: FnOnce() -> ForgeResult<T> + Send + 'static, T: Send + 'static,

安全地在异步上下文中执行可能阻塞的操作

此方法会将阻塞操作移到专用的阻塞线程池中执行