Lớp đồng hồ bấm giờ trong python

Chạy cho đến khi tương lai [một phiên bản của] hoàn thành

Nếu đối số là a thì nó được lên lịch ngầm định để chạy dưới dạng

Trả lại kết quả của Tương lai hoặc tăng ngoại lệ của nó

Chạy vòng lặp sự kiện cho đến khi được gọi

Nếu được gọi trước khi được gọi, vòng lặp sẽ thăm dò bộ chọn I/O một lần với thời gian chờ bằng 0, chạy tất cả các lệnh gọi lại đã lên lịch để phản hồi các sự kiện I/O [và những cuộc gọi đã được lên lịch], sau đó thoát

Nếu được gọi trong khi đang chạy, vòng lặp sẽ chạy lô gọi lại hiện tại rồi thoát. Lưu ý rằng các cuộc gọi lại mới được lên lịch bởi các cuộc gọi lại sẽ không chạy trong trường hợp này;

Dừng vòng lặp sự kiện

Trả lại

srv = await loop.create_server[...]

async with srv:
    # some code

# At this point, srv is closed and no longer accepts new connections.

Trả lại

srv = await loop.create_server[...]

async with srv:
    # some code

# At this point, srv is closed and no longer accepts new connections.

Đóng vòng lặp sự kiện

Vòng lặp không được chạy khi chức năng này được gọi. Mọi cuộc gọi lại đang chờ xử lý sẽ bị loại bỏ

Phương pháp này xóa tất cả các hàng đợi và tắt trình thực thi, nhưng không đợi trình thực thi kết thúc

Phương pháp này là idempotent và không thể đảo ngược. Không có phương thức nào khác được gọi sau khi vòng lặp sự kiện được đóng lại

Lên lịch tất cả các đối tượng hiện đang mở để đóng bằng một cuộc gọi. Sau khi gọi phương thức này, vòng lặp sự kiện sẽ đưa ra cảnh báo nếu một trình tạo không đồng bộ mới được lặp lại. Điều này nên được sử dụng để hoàn thiện một cách đáng tin cậy tất cả các trình tạo không đồng bộ theo lịch trình

Lưu ý rằng không cần gọi chức năng này khi được sử dụng

Ví dụ

try:
    loop.run_forever[]
finally:
    loop.run_until_complete[loop.shutdown_asyncgens[]]
    loop.close[]

Mới trong phiên bản 3. 6

Lên lịch đóng trình thực thi mặc định và đợi nó tham gia tất cả các luồng trong

async def client_connected[reader, writer]:
    # Communicate with the client with
    # reader/writer streams.  For example:
    await reader.readline[]

async def main[host, port]:
    srv = await asyncio.start_server[
        client_connected, host, port]
    await srv.serve_forever[]

asyncio.run[main['127.0.0.1', 0]]

Lưu ý rằng không cần gọi chức năng này khi được sử dụng

Mới trong phiên bản 3. 9

Lên lịch gọi lại để được gọi với các đối số args ở lần lặp tiếp theo của vòng lặp sự kiện

Các cuộc gọi lại được gọi theo thứ tự mà chúng được đăng ký. Mỗi cuộc gọi lại sẽ được gọi chính xác một lần

Đối số ngữ cảnh chỉ từ khóa tùy chọn cho phép chỉ định một tùy chỉnh để gọi lại chạy trong. Ngữ cảnh hiện tại được sử dụng khi không có ngữ cảnh nào được cung cấp

Một phiên bản của được trả về, có thể được sử dụng sau này để hủy cuộc gọi lại

Phương pháp này không an toàn cho luồng

Một biến thể thread-safe của. Phải được sử dụng để lên lịch gọi lại từ một luồng khác

Tăng nếu được gọi trên một vòng lặp đã bị đóng. Điều này có thể xảy ra trên luồng phụ khi ứng dụng chính đang tắt

Xem phần tài liệu

Đã thay đổi trong phiên bản 3. 7. Đã thêm thông số ngữ cảnh chỉ từ khóa. Xem PEP 567 để biết thêm chi tiết.

Ghi chú

Hầu hết các chức năng lập lịch trình không cho phép chuyển các đối số từ khóa. Để làm điều đó, sử dụng

# will schedule "print["Hello", flush=True]"
loop.call_soon[
    functools.partial[print, "Hello", flush=True]]

Sử dụng các đối tượng một phần thường thuận tiện hơn so với sử dụng lambdas, vì asyncio có thể hiển thị các đối tượng một phần tốt hơn trong thông báo lỗi và gỡ lỗi

Vòng lặp sự kiện cung cấp các cơ chế để lên lịch các chức năng gọi lại sẽ được gọi vào một thời điểm nào đó trong tương lai. Vòng lặp sự kiện sử dụng đồng hồ đơn điệu để theo dõi thời gian

Lên lịch gọi lại để được gọi sau số giây trì hoãn nhất định [có thể là int hoặc float]

Một phiên bản của được trả về có thể được sử dụng để hủy cuộc gọi lại

gọi lại sẽ được gọi chính xác một lần. Nếu hai cuộc gọi lại được lên lịch chính xác cùng một lúc, thứ tự mà chúng được gọi là không xác định

Các đối số vị trí tùy chọn sẽ được chuyển đến hàm gọi lại khi nó được gọi. Nếu bạn muốn gọi lại với các đối số từ khóa, hãy sử dụng

Đối số ngữ cảnh chỉ từ khóa tùy chọn cho phép chỉ định một tùy chỉnh để gọi lại chạy trong. Ngữ cảnh hiện tại được sử dụng khi không có ngữ cảnh nào được cung cấp

Đã thay đổi trong phiên bản 3. 7. Đã thêm thông số ngữ cảnh chỉ từ khóa. Xem PEP 567 để biết thêm chi tiết.

Đã thay đổi trong phiên bản 3. 8. Trong Python 3. 7 trở về trước với việc triển khai vòng lặp sự kiện mặc định, độ trễ không thể vượt quá một ngày. Điều này đã được sửa trong Python 3. 8.

Lên lịch gọi lại để được gọi tại dấu thời gian tuyệt đối đã cho khi [một số nguyên hoặc số float], sử dụng cùng tham chiếu thời gian như

Hành vi của phương pháp này giống như

Một phiên bản của được trả về có thể được sử dụng để hủy cuộc gọi lại

Đã thay đổi trong phiên bản 3. 7. Đã thêm thông số ngữ cảnh chỉ từ khóa. Xem PEP 567 để biết thêm chi tiết.

Đã thay đổi trong phiên bản 3. 8. Trong Python 3. 7 trở về trước với việc triển khai vòng lặp sự kiện mặc định, sự khác biệt giữa thời điểm và thời gian hiện tại không thể vượt quá một ngày. Điều này đã được sửa trong Python 3. 8.

Trả về thời gian hiện tại, dưới dạng một giá trị, theo đồng hồ đơn điệu bên trong của vòng lặp sự kiện

Ghi chú

Đã thay đổi trong phiên bản 3. 8. Trong Python 3. 7 và thời gian chờ sớm hơn [độ trễ tương đối hoặc thời điểm tuyệt đối] không được vượt quá một ngày. Điều này đã được sửa trong Python 3. 8.

Xem thêm

Chức năng

Tạo một đối tượng được gắn vào vòng lặp sự kiện

Đây là cách ưa thích để tạo Futures trong asyncio. Điều này cho phép các vòng lặp sự kiện của bên thứ ba cung cấp các triển khai thay thế của đối tượng Tương lai [với hiệu suất hoặc công cụ tốt hơn]

Mới trong phiên bản 3. 5. 2

Lên lịch thực hiện coro. Trả lại một đối tượng

Các vòng lặp sự kiện của bên thứ ba có thể sử dụng lớp con riêng của chúng để có khả năng tương tác. Trong trường hợp này, loại kết quả là một lớp con của

Nếu đối số tên được cung cấp và không phải là

import asyncio

def hello_world[loop]:
    """A callback to print 'Hello World' and stop the event loop"""
    print['Hello World']
    loop.stop[]

loop = asyncio.new_event_loop[]

# Schedule a call to hello_world[]
loop.call_soon[hello_world, loop]

# Blocking call interrupted by loop.stop[]
try:
    loop.run_forever[]
finally:
    loop.close[]

Đối số ngữ cảnh chỉ từ khóa tùy chọn cho phép chỉ định tùy chỉnh cho coro chạy trong. Bản sao ngữ cảnh hiện tại được tạo khi không có ngữ cảnh nào được cung cấp

Đã thay đổi trong phiên bản 3. 8. Đã thêm thông số tên.

Đã thay đổi trong phiên bản 3. 11. Đã thêm tham số ngữ cảnh.

Đặt một nhà máy nhiệm vụ sẽ được sử dụng bởi

Nếu nhà máy là

import asyncio

def hello_world[loop]:
    """A callback to print 'Hello World' and stop the event loop"""
    print['Hello World']
    loop.stop[]

loop = asyncio.new_event_loop[]

# Schedule a call to hello_world[]
loop.call_soon[hello_world, loop]

# Blocking call interrupted by loop.stop[]
try:
    loop.run_forever[]
finally:
    loop.close[]

import asyncio

def hello_world[loop]:
    """A callback to print 'Hello World' and stop the event loop"""
    print['Hello World']
    loop.stop[]

loop = asyncio.new_event_loop[]

# Schedule a call to hello_world[]
loop.call_soon[hello_world, loop]

# Blocking call interrupted by loop.stop[]
try:
    loop.run_forever[]
finally:
    loop.close[]

Trả lại nhà máy nhiệm vụ hoặc

import asyncio

def hello_world[loop]:
    """A callback to print 'Hello World' and stop the event loop"""
    print['Hello World']
    loop.stop[]

loop = asyncio.new_event_loop[]

# Schedule a call to hello_world[]
loop.call_soon[hello_world, loop]

# Blocking call interrupted by loop.stop[]
try:
    loop.run_forever[]
finally:
    loop.close[]

Mở kết nối truyền phát trực tuyến đến một địa chỉ nhất định được chỉ định bởi máy chủ và cổng

Họ ổ cắm có thể là hoặc tùy thuộc vào Máy chủ [hoặc đối số họ, nếu được cung cấp]

Loại ổ cắm sẽ là

protocol_factory phải có thể gọi được khi trả về một triển khai

Phương pháp này sẽ cố gắng thiết lập kết nối trong nền. Khi thành công, nó sẽ trả về một cặp

import asyncio
import datetime

def display_date[end_time, loop]:
    print[datetime.datetime.now[]]
    if [loop.time[] + 1.0]