API 参考
APIFuture
异步操作的通用接口
类
APIFuture<T>
表示将产生类型 T 值的异步操作的抽象泛型类。
AwaitableConcurrentFuture<T>
包装 Python 的 concurrent.futures.Future 并支持 async/await 的具体实现。
方法
result_async
async def result_async(timeout: Optional[float] = None) -> T异步获取结果(非阻塞)。
参数:
timeout:可选 timeout(秒)
抛出:操作未在 timeout 内完成则抛出 TimeoutError。
result
def result(timeout: Optional[float] = None) -> T同步获取结果(阻塞)。
参数:
timeout:可选 timeout(秒)
抛出:操作未在 timeout 内完成则抛出 TimeoutError。
future
def future() -> concurrent.futures.Future\[T\]访问底层的 concurrent.futures.Future 对象。
使用方法
异步
api_future = await client.some_operation_async(...)
result = await api_future同步
api_future = client.some_operation(...)
result = api_future.result()带 Timeout
try:
result = api_future.result(timeout=30.0) # 30 秒
except TimeoutError:
print("操作超时")