Sự kiện có nghĩa là gì trong Python?

Run until the future [an instance of ] has completed

If the argument is a it is implicitly scheduled to run as a

Return the Future’s result or raise its exception

Run the event loop until is called

If is called before is called, the loop will poll the I/O selector once with a timeout of zero, run all callbacks scheduled in response to I/O events [and those that were already scheduled], and then exit

If is called while is running, the loop will run the current batch of callbacks and then exit. Note that new callbacks scheduled by callbacks will not run in this case; instead, they will run the next time or is called

Stop the event loop

Return

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.

Close the event loop

The loop must not be running when this function is called. Any pending callbacks will be discarded

This method clears all queues and shuts down the executor, but does not wait for the executor to finish

This method is idempotent and irreversible. No other methods should be called after the event loop is closed

Schedule all currently open objects to close with an call. After calling this method, the event loop will issue a warning if a new asynchronous generator is iterated. This should be used to reliably finalize all scheduled asynchronous generators

Note that there is no need to call this function when is used

Example

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

New in version 3. 6

Schedule the closure of the default executor and wait for it to join all of the threads in the

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]]

Note that there is no need to call this function when is used

New in version 3. 9

Schedule the callback to be called with args arguments at the next iteration of the event loop

Callbacks are called in the order in which they are registered. Each callback will be called exactly once

An optional keyword-only context argument allows specifying a custom for the callback to run in. The current context is used when no context is provided

An instance of is returned, which can be used later to cancel the callback

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

A thread-safe variant of . Must be used to schedule callbacks from another thread

Raises if called on a loop that’s been closed. This can happen on a secondary thread when the main application is shutting down

See the section of the documentation

Changed in version 3. 7. The context keyword-only parameter was added. See PEP 567 for more details.

Ghi chú

Most scheduling functions don’t allow passing keyword arguments. To do that, use

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

Using partial objects is usually more convenient than using lambdas, as asyncio can render partial objects better in debug and error messages

Event loop provides mechanisms to schedule callback functions to be called at some point in the future. Event loop uses monotonic clocks to track time

Schedule callback to be called after the given delay number of seconds [can be either an int or a float]

An instance of is returned which can be used to cancel the callback

callback will be called exactly once. If two callbacks are scheduled for exactly the same time, the order in which they are called is undefined

The optional positional args will be passed to the callback when it is called. If you want the callback to be called with keyword arguments use

An optional keyword-only context argument allows specifying a custom for the callback to run in. The current context is used when no context is provided

Changed in version 3. 7. The context keyword-only parameter was added. See PEP 567 for more details.

Changed in version 3. 8. In Python 3. 7 and earlier with the default event loop implementation, the delay could not exceed one day. This has been fixed in Python 3. 8.

Schedule callback to be called at the given absolute timestamp when [an int or a float], using the same time reference as

This method’s behavior is the same as

An instance of is returned which can be used to cancel the callback

Changed in version 3. 7. The context keyword-only parameter was added. See PEP 567 for more details.

Changed in version 3. 8. In Python 3. 7 and earlier with the default event loop implementation, the difference between when and the current time could not exceed one day. Đ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. This lets third-party event loops provide alternative implementations of the Future object [with better performance or instrumentation]

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

Schedule the execution of coro. Return a object

Third-party event loops can use their own subclass of for interoperability. In this case, the result type is a subclass of

If the name argument is provided and not

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[]

An optional keyword-only context argument allows specifying a custom for the coro to run in. The current context copy is created when no context is provided

Changed in version 3. 8. Added the name parameter.

Changed in version 3. 11. Added the context parameter.

Set a task factory that will be used by

If factory is

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[]

Return a task factory or

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[]

Open a streaming transport connection to a given address specified by host and port

The socket family can be either or depending on host [or the family argument, if provided]

The socket type will be

protocol_factory must be a callable returning an implementation

This method will try to establish the connection in the background. When successful, it returns a

import asyncio
import datetime

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