Python gọi chức năng async đồng bộ

Nếu bạn chạy một hàm chỉ chặn và khiến Python đợi ở đó mà không sử dụng

# Code above omitted 👆

def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"

# Code below omitted 👇

Điều này được gọi để chặn vòng lặp sự kiện (vòng lặp sự kiện là thứ chạy các chức năng không đồng bộ lần lượt nhảy tại các điểm

# Code above omitted 👆

def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"

# Code below omitted 👇

Hãy xem cách mà Asyncer's

# Code above omitted 👆

def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"

# Code below omitted 👇

Chặn vòng lặp sự kiện¶

Trước tiên hãy xem một ví dụ bị hỏng

Đồng bộ hóa công việc¶

Hãy xem chức năng đồng bộ hóa (thông thường, chặn)

# 🚨 Don't use this, it will block the event loop! 🚨

import time

import anyio


def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"


async def main():
    message = do_sync_work(name="World")
    print(message)


anyio.run(main)

# Code above omitted 👆

def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"

# Code below omitted 👇

# 🚨 Don't use this, it will block the event loop! 🚨

import time

import anyio


def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"


async def main():
    message = do_sync_work(name="World")
    print(message)


anyio.run(main)

Chức năng này có thể nói chuyện với cơ sở dữ liệu, API từ xa, v.v. Nhưng nó không sử dụng

# Code above omitted 👆

def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"

# Code below omitted 👇

# 🚨 Don't use this, it will block the event loop! 🚨

import time

import anyio


def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"


async def main():
    message = do_sync_work(name="World")
    print(message)


anyio.run(main)

Mã đồng bộ hóa cuộc gọi từ Chặn mã không đồng bộ¶

Đây là vấn đề

Chúng ta hãy gọi chức năng đồng bộ hóa chậm (thông thường, chặn) đó trực tiếp từ bên trong mã async 😱

# 🚨 Don't use this, it will block the event loop! 🚨

import time

import anyio


def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"


async def main():
    message = do_sync_work(name="World")
    print(message)


anyio.run(main)

Bởi vì chức năng đó không phải là không đồng bộ, nhưng nó vẫn khiến Python chờ ở đó, nó sẽ cản trở bất kỳ mã không đồng bộ nào khác có thể đã được bắt đầu chạy. Tất cả sẽ phải đứng đó mà không làm gì cả, tốn thời gian tính toán. 😭

Sử dụng Asyncify¶

Trong những trường hợp bạn muốn chạy mã "đồng bộ" (đồng bộ, chặn) từ bên trong mã không đồng bộ theo cách tương thích với phần còn lại của mã không đồng bộ, bạn có thể sử dụng Asyncer's

# Code above omitted 👆

def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"

# Code below omitted 👇

import time

import anyio
from asyncer import asyncify


def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"


async def main():
    message = await asyncify(do_sync_work)(name="World")
    print(message)


anyio.run(main)

# Code above omitted 👆

def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"

# Code below omitted 👇

Khi bạn gọi nó, Asyncer (sử dụng AnyIO) sẽ chạy chức năng đó theo cách không chặn vòng lặp sự kiện

Sau đó, bạn có thể

# Code above omitted 👆

def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"

# Code below omitted 👇

Lưu ý rằng bây giờ hàm

# 🚨 Don't use this, it will block the event loop! 🚨

import time

import anyio


def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"


async def main():
    message = do_sync_work(name="World")
    print(message)


anyio.run(main)

# 🚨 Don't use this, it will block the event loop! 🚨

import time

import anyio


def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"


async def main():
    message = do_sync_work(name="World")
    print(message)


anyio.run(main)

# Code above omitted 👆

def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"

# Code below omitted 👇

import time

import anyio
from asyncer import asyncify


def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"


async def main():
    message = await asyncify(do_sync_work)(name="World")
    print(message)


anyio.run(main)

nó thậm chí còn có một dòng

# Code above omitted 👆

def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"

# Code below omitted 👇

để mô phỏng hoạt động chặn (không sử dụng

# Code above omitted 👆

def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"

# Code below omitted 👇

Đó có thể là đọc tệp, nói chuyện với cơ sở dữ liệu, v.v.

Nhưng

# Code above omitted 👆

def do_sync_work(name: str):
    time.sleep(1)
    return f"Hello, {name}"

# Code below omitted 👇

Hỗ trợ đánh máy¶

Và tất nhiên, do cách thiết kế của Assyncer, bạn sẽ nhận được hỗ trợ gõ với các lỗi nội tuyến và tự động hoàn thành các đối số của hàm

Và bạn cũng sẽ nhận được hỗ trợ gõ cho giá trị trả về

Và nếu bạn đã sử dụng các công cụ như mypy, những công cụ đó cũng có thể sử dụng hỗ trợ đánh máy này để giúp bạn đảm bảo mã của mình chính xác và ngăn ngừa nhiều lỗi. 😎

Tôi có thể gọi hàm async từ Sync Python không?

Python có đồng bộ hay không đồng bộ không?

Không đồng bộ có nhanh hơn đồng bộ hóa Python không?

Bạn có thể đợi chức năng Python không đồng bộ không?