Python多线程与异步IO混合编程实践：解决“There is no current event loop“问题

ERROR - There is no current event loop in thread 'Thread-4'.

from concurrent.futures import ThreadPoolExecutor
import asyncio

async def async_task():
    await asyncio.sleep(1)
    return "Done"

def run_in_thread():
    # 直接调用会报错：There is no current event loop in thread
    result = async_task()  # ❌ 错误！
    return result

with ThreadPoolExecutor() as executor:
    future = executor.submit(run_in_thread)
    print(future.result())

import requests

def sf_express_order_count_sync(consigneePhone, cookie, createTimeStart, createTimeEnd):
    """同步版：使用requests发送HTTP请求"""
    url = 'https://sd.sf-express.com/api/merge/order/count'
    response = requests.post(url, headers=headers, json=payload)
    return response.json()

import aiohttp

async def sf_express_order_count_async(consigneePhone, cookie, createTimeStart, createTimeEnd):
    """异步版：使用aiohttp"""
    async with aiohttp.ClientSession() as session:
        async with session.post(url, headers=headers, json=payload) as resp:
            return await resp.json()

def run_async_in_thread(async_func, *args):
    """在子线程中运行异步函数"""
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    try:
        return loop.run_until_complete(async_func(*args))
    finally:
        loop.close()

# 在线程池中调用
with ThreadPoolExecutor() as executor:
    future = executor.submit(
        run_async_in_thread, 
        sf_express_order_count_async, 
        "13112345678", 
        "cookie123", 
        1630000000
    )
    print(future.result())

from concurrent.futures import ProcessPoolExecutor

def check_phones_with_processes(phone_numbers):
    """使用进程池规避GIL和事件循环问题"""
    with ProcessPoolExecutor() as executor:
        futures = [executor.submit(has_orders, phone) for phone in phone_numbers]
        for future in as_completed(futures):
            if future.result():
                return future.result()

import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.util.concurrent.CompletableFuture;

public class SfExpressChecker {
    private static final HttpClient httpClient = HttpClient.newHttpClient();

    public static CompletableFuture<Boolean> hasOrdersAsync(String phone, String cookie) {
        HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create("https://sd.sf-express.com/api/merge/order/count"))
                .header("Content-Type", "application/json")
                .header("token", cookie)
                .POST(HttpRequest.BodyPublishers.ofString(
                    String.format("{\"consigneePhone\":\"%s\"}", phone)))
                .build();

        return httpClient.sendAsync(request, HttpResponse.BodyHandlers.ofString())
                .thenApply(response -> {
                    JsonObject json = JsonParser.parseString(response.body()).getAsJsonObject();
                    return json.get("result").getAsJsonObject().get("total").getAsInt() > 0;
                });
    }

    public static void main(String[] args) {
        CompletableFuture<Boolean> future = hasOrdersAsync("13112345678", "cookie123");
        future.thenAccept(hasOrders -> System.out.println("Has orders: " + hasOrders));
        future.join(); // 阻塞等待结果
    }
}