java异步编程之一文看完其异步函数表

目录
  • 1 低层级 asyncio 索引
    • 1.1 获取事件循环
    • 1.2 事件循环方法集
    • 1.3 传输
      • 1.3.1 读取传输
      • 1.3.2 写入传输
      • 1.3.3 数据报传输
      • 1.3.4 子进程传输
      • 1.3.5 协议
      • 1.3.6 流协议 (TCP, Unix 套接字, 管道)
      • 1.3.7 缓冲流协议
      • 1.3.8 数据报协议
      • 1.3.9 子进程协议
    • 事件循环策略
  • 2 高层 API索引
    • 2.1 任务
      • 例子
    • 2 队列集
    • 2.1 子进程集
    • 3 同步
  • 小结

1 低层级 asyncio 索引

低层级 API 索引¶ 列出所有低层级的 asyncio API。

1.1 获取事件循环

获取当前运行的事件循环 首选 函数:

asyncio.get_running_loop()

获得一个事件循环实例(当前或通过策略):

asyncio.get_event_loop()

通过当前策略将事件循环设置当前事件循环:

asyncio.set_event_loop()

创建一个新的事件循环:

asyncio.new_event_loop()

例子:

使用asyncio.get_running_loop()

1.2 事件循环方法集

  • 查阅

事件循环方法 相关的主要文档段落 。生命周期

运行一个期程/任务/可等待对象直到完成:

loop.run_until_complete()

一直运行事件循环:

loop.run_forever()

停止事件循环:

loop.stop()

关闭事件循环:

loop.close()

返回 True , 如果事件循环正在运行:

loop.is_running()

返回 True ,如果事件循环已经被关闭:

loop.is_closed()

关闭异步生成器:

await loop.shutdown_asyncgens()
  • 调试:

开启或禁用调试模式:

loop.set_debug()

获取当前测试模式:

loop.get_debug()

调度回调函数:

loop.call_soon()

尽快调用回调:

loop.call_soon_threadsafe()

方法线程安全的变体:

	loop.call_soon()

在给定时间 之后 调用回调函数:

loop.call_later()

在 指定 时间调用回调函数:

loop.call_at()
  • 线程/进程池

在 concurrent.futures 执行器中运行一个独占CPU或其它阻塞函数:

await loop.run_in_executor()

设置 loop.run_in_executor() 默认执行器:

loop.set_default_executor()
  • 任务与期程

创建一个 Future 对象:

loop.create_future()

将协程当作 Task 一样调度:

loop.create_task()

设置 loop.create_task() 使用的工厂,它将用来创建 Tasks:

loop.set_task_factory()

获取 loop.create_task() 使用的工厂,它用来创建 Tasks:

loop.get_task_factory()

异步版的 socket.getaddrinfo():

await loop.getaddrinfo()

异步版的 socket.getnameinfo():

await loop.getnameinfo()
  • 网络和IPC

打开一个TCP链接:

await loop.create_connection()

创建一个TCP服务:

await loop.create_server()

打开一个Unix socket连接:

await loop.create_unix_connection()

创建一个Unix socket服务:

await loop.create_unix_server()

将 socket 包装成 (transport, protocol) 对:

await loop.connect_accepted_socket()

打开一个数据报(UDP)连接:

await loop.create_datagram_endpoint()

通过传输通道发送一个文件:

await loop.sendfile()

将一个已建立的链接升级到TLS:

await loop.start_tls()

将管道读取端包装成 (transport, protocol) 对:

await loop.connect_read_pipe()

将管道写入端包装成 (transport, protocol) 对:

await loop.connect_write_pipe()
  • 套接字

从 socket 接收数据:

await loop.sock_recv()

从 socket 接收数据到一个缓冲区中:

await loop.sock_recv_into()

发送数据到 socket :

await loop.sock_sendall()

链接 await loop.sock_connect() :

await loop.sock_connect()

接受一个 socket 链接:

await loop.sock_accept()

利用 socket 发送一个文件:

await loop.sock_sendfile()

开始对一个文件描述符的可读性的监视:

loop.add_reader()

停止对一个文件描述符的可读性的监视:

loop.remove_reader()

开始对一个文件描述符的可写性的监视:

loop.add_writer()

停止对一个文件描述符的可写性的监视:

loop.remove_writer()
  • Unix信号

给 signal 添加一个处理回调函数:

loop.add_signal_handler()

删除 signal 的处理回调函数:

loop.remove_signal_handler()
  • 子进程集

衍生一个子进程:

loop.subprocess_exec()

从终端命令衍生一个子进程:

loop.subprocess_shell()
  • 错误处理

调用异常处理器:

loop.call_exception_handler()

设置一个新的异常处理器:

loop.set_exception_handler()

获取当前异常处理器:

loop.get_exception_handler()

默认异常处理器实现:

loop.default_exception_handler()
  • 例子

    使用 asyncio.get_event_loop() 和 loop.run_forever().

    使用 loop.call_later().

    使用 loop.create_connection() 实现 echo客户端.

    使用 loop.create_connection() 去 链接socket.

    使用add_reader()监听FD(文件描述符)的读取事件.

    使用loop.add_signal_handler().

    使用loop.add_signal_handler()。

1.3 传输

所有传输都实现以下方法:

transport.close()

关闭传输。

transport.is_closing()

返回 True ,如果传输正在关闭或已经关闭。

transport.get_extra_info()

请求传输的相关信息。

transport.set_protocol()

设置一个新协议。

transport.get_protocol()

返回当前协议。

传输可以接收数据(TCP和Unix链接,管道等)。它通过 loop.create_connection(), loop.create_unix_connection(), loop.connect_read_pipe() 等方法返回。

1.3.1 读取传输

返回 True ,如果传输正在接收:

transport.is_reading()

暂停接收:

transport.pause_reading()

继续接收:

transport.resume_reading()

传输可以发送数据(TCP和Unix链接,管道等)。它通过 loop.create_connection(), loop.create_unix_connection(), loop.connect_write_pipe() 等方法返回。

1.3.2 写入传输

向传输写入数据:

transport.write()

向传输写入缓冲:

transport.write()

返回 True ,如果传输支持发送 EOF:

transport.can_write_eof()

在冲洗已缓冲的数据后关闭传输和发送EOF:

transport.write_eof()

立即关闭传输:

transport.abort()

返回写入流控制的高位标记位和低位标记位:

transport.get_write_buffer_size()

设置新的写入流控制的高位标记位和低位标记位:

transport.set_write_buffer_limits()

由 loop.create_datagram_endpoint() 返回的传输:

1.3.3 数据报传输

发送数据到远程链接端:

transport.sendto()

立即关闭传输:

transport.abort()

基于子进程的底层抽象传输,它由 loop.subprocess_exec() 和 loop.subprocess_shell() 返回:

1.3.4 子进程传输

返回子进程的进程ID:

transport.get_pid()

返回请求通信管道 (stdin, stdout, 或 stderr)的传输:

transport.get_pipe_transport()

返回子进程的返回代号:

transport.get_returncode()

杀死子进程:

transport.kill()

发送一个信号到子进程:

transport.send_signal()

停止子进程:

transport.terminate()

杀死子进程并关闭所有管道:

transport.close()

1.3.5 协议

协议类可以由下面 回调方法 实现:

连接建立时被调用:

callback connection_made()

连接丢失或关闭时将被调用:

callback connection_lost()

传输的缓冲区超过高位标记位时被调用:

callback pause_writing()

传输的缓冲区传送到低位标记位时被调用:

callback resume_writing()

1.3.6 流协议 (TCP, Unix 套接字, 管道)

接收到数据时被调用:

callback data_received()

接收到EOF时被调用:

callback eof_received()

1.3.7 缓冲流协议

调用后会分配新的接收缓冲区:

callback get_buffer()

用接收的数据更新缓冲区时被调用:

callback buffer_updated()

接收到EOF时被调用:

callback eof_received()

1.3.8 数据报协议

接收到数据报时被调用:

callback datagram_received()

前一个发送或接收操作引发 OSError 时被调用:

callback error_received()

1.3.9 子进程协议

子进程向 stdout 或 stderr 管道写入数据时被调用:

callback pipe_data_received()

与子进程通信的其中一个管道关闭时被调用:

callback pipe_connection_lost()

子进程退出时被调用:

callback process_exited()

事件循环策略

策略是改变 asyncio.get_event_loop() 这类函数行为的一个底层机制。更多细节可以查阅 策略部分。

访问策略

asyncio.get_event_loop_policy()

返回当前进程域的策略。

asyncio.set_event_loop_policy()

设置一个新的进程域策略。

AbstractEventLoopPolicy

策略对象的基类。

2 高层 API索引

列举了所有能用于 async/wait 的高层级asyncio API 集。

2.1 任务

运行异步程序,创建Task对象,等待多件事运行超时的公共集。

run()

创建事件循环,运行一个协程,关闭事件循环。

create_task()

启动一个asyncio的Task对象。

await sleep()

休眠几秒。

await gather()

并发执行所有事件的调度和等待。

await wait_for()

有超时控制的运行。

await shield()

屏蔽取消操作

await wait()

完成情况的监控器

current_task()

返回当前Task对象

all_tasks()

返回事件循环中所有的task对象。

Task

Task对象

to_thread()

在不同的 OS 线程中异步地运行一个函数。

run_coroutine_threadsafe()

从其他OS线程中调度一个协程。

for in as_completed()

用 for 循环监控完成情况。

例子

使用 asyncio.gather() 并行运行. 使用 asyncio.wait_for() 强制超时.

撤销协程.

	asyncio.sleep() 的用法.

请主要参阅 协程与任务文档.

2 队列集

队列集被用于多个异步Task对象的运行调度,实现连接池以及发布/订阅模式。

先进先出队列

Queue

优先级队列:

  PriorityQueue

后进先出队列:

LifoQueue

使用 asyncio.Queue 在多个并发任务间分配工作量.

2.1 子进程集

用于生成子进程和运行shell命令的工具包。

创建一个子进程:

await create_subprocess_exec()

运行一个shell命令:

await create_subprocess_shell()

比如使用 它执行一个shell命令. 请参阅 子进程 APIs 相关文档.

3 同步

能被用于Task对象集的,类似线程的同步基元组件。

互斥锁:

Lock

事件对象:

Event

条件对象:

Condition

信号量:

Semaphore

有界的信号量:

BoundedSemaphore

小结

使用异步库的例子

asyncio.Event 的用法.

请参阅asyncio文档 synchronization primitives.

异常

asyncio.TimeoutError

类似 wait_for() 等函数在超时时候被引发。请注意 asyncio.TimeoutError 与内建异常 TimeoutError 无关。

asyncio.CancelledError

当一个Task对象被取消的时候被引发。请参阅 Task.cancel()。 在取消请求发生的运行代码中如何处理CancelledError异常.

请参阅完整的 asyncio 专用异常 列表.

本文代码例子

以上就是java异步编程之一文看完其异步函数表的详细内容,更多关于java异步函数表的资料请关注我们其它相关文章!

(0)

相关推荐

  • java异步编程CompletableFuture使用示例详解

    目录 一.简单介绍 二.常见操作 1.使用默认线程池 2.使用自定义线程池 3.获取线程的执行结果 三.处理异步结算的结果 四.异常处理 五.组合 CompletableFuture 六.并行运行多个 CompletableFuture 七.案例 1.从多个平台获取书价格 2.从任意一个平台获取结果就返回 一.简单介绍 CompletableFuture 同时实现了 Future 和 CompletionStage 接口. public class CompletableFuture<T> i

  • Java CompletableFuture实现多线程异步编排

    目录 一 :问题背景 二 :CompletableFuture介绍 三 :具体场景 1.0 单个任务 1.0.1 runAsync:无返回值 1.0.2 supplyAsync:有返回值 1.0.3 supplyAsync:有返回值 2.0 两个任务编排 2.0.1 thenRunAsync 2.0.2 thenAcceptAsync 2.0.3 thenApplyAsync 3.0 三任务编排 3.0.1 三任务组合 3.0.2 三任务组合二 4.0 多任务的编排 4.0.1.allOf:所有

  • java开发线上事故理解RocketMQ异步精髓

    目录 引言 1 业务场景 2 线程池模式 3 本地内存 + 定时任务 4 MQ 模式 5 Agent 服务 + MQ 模式 6 总结 第一层:什么场景下需要异步 第二层:异步的外功心法 第三层:异步的本质 引言 在高并发的场景下,异步是一个极其重要的优化方向. 前段时间,生产环境发生一次事故,笔者认为事故的场景非常具备典型性 . 写这篇文章,笔者想和大家深入探讨该场景的架构优化方案.希望大家读完之后,可以对异步有更深刻的理解. 1 业务场景 老师登录教研平台,会看到课程列表,点击课程后,课程会以

  • java CompletableFuture异步任务编排示例详解

    目录 前言 同步串行 异步串行 并行任务 多任务结果合并计算 任一任务完成 快速失败 注意 前言 在之前的项目开发中,都没怎么使用过CompletableFuture的功能,只听说过和异步编程有关.为了能够在将来有需要的时候用得上,这两天花了点时间学习了一下,并简单地总结一下如何使用CompletableFuture完成异步任务编排. 先创建一个自定义的线程池,后续所有代码都会使用到: private static final ThreadPoolExecutor THREAD_POOL_EXE

  • java异步编程之一文看完其异步函数表

    目录 1 低层级 asyncio 索引 1.1 获取事件循环 1.2 事件循环方法集 1.3 传输 1.3.1 读取传输 1.3.2 写入传输 1.3.3 数据报传输 1.3.4 子进程传输 1.3.5 协议 1.3.6 流协议 (TCP, Unix 套接字, 管道) 1.3.7 缓冲流协议 1.3.8 数据报协议 1.3.9 子进程协议 事件循环策略 2 高层 API索引 2.1 任务 例子 2 队列集 2.1 子进程集 3 同步 小结 1 低层级 asyncio 索引 低层级 API 索引¶

  • Java 并发编程:volatile的使用及其原理解析

    Java并发编程系列[未完]: •Java 并发编程:核心理论 •Java并发编程:Synchronized及其实现原理 •Java并发编程:Synchronized底层优化(轻量级锁.偏向锁) •Java 并发编程:线程间的协作(wait/notify/sleep/yield/join) •Java 并发编程:volatile的使用及其原理 一.volatile的作用 在<Java并发编程:核心理论>一文中,我们已经提到过可见性.有序性及原子性问题,通常情况下我们可以通过Synchroniz

  • 跟我学习javascript解决异步编程异常方案

    一.JavaScript异步编程的两个核心难点 异步I/O.事件驱动使得单线程的JavaScript得以在不阻塞UI的情况下执行网络.文件访问功能,且使之在后端实现了较高的性能.然而异步风格也引来了一些麻烦,其中比较核心的问题是: 1.函数嵌套过深 JavaScript的异步调用基于回调函数,当多个异步事务多级依赖时,回调函数会形成多级的嵌套,代码变成 金字塔型结构.这不仅使得代码变难看难懂,更使得调试.重构的过程充满风险. 2.异常处理 回调嵌套不仅仅是使代码变得杂乱,也使得错误处理更复杂.这

  • .NET中的异步编程-EAP/APM使用方法及案例介绍

    从.NET 4.5开始,支持的三种异步编程模式: •基于事件的异步编程设计模式 (EAP,Event-based Asynchronous Pattern) •异步编程模型(APM,Asynchronous Programming Model) •基于任务的编程模型(TAP,Task-based Asynchronous Pattern) 基于任务的异步模式 (TAP) 是基于 System.Threading.Tasks 命名空间的 Task 和 Task<TResult>,用于表示任意异步

  • 深入分析C#异步编程详解

    同步方法和异步方法的区别同步方法调用在程序继续执行之前需要等待同步方法执行完毕返回结果异步方法则在被调用之后立即返回以便程序在被调用方法完成其任务的同时执行其它操作异步编程概览.NET Framework 允许您异步调用任何方法.定义与您需要调用的方法具有相同签名的委托:公共语言运行库将自动为该委托定义具有适当签名的 BeginInvoke 和 EndInvoke 方法.BeginInvoke 方法用于启动异步调用.它与您需要异步执行的方法具有相同的参数,只不过还有两个额外的参数(将在稍后描述)

  • python并发和异步编程实例

    关于并发.并行.同步阻塞.异步非阻塞.线程.进程.协程等这些概念,单纯通过文字恐怕很难有比较深刻的理解,本文就通过代码一步步实现这些并发和异步编程,并进行比较.解释器方面本文选择python3,毕竟python3才是python的未来,并且python3用原生的库实现协程已经非常方便了. 1.准备阶段 下面为所有测试代码所需要的包 #! python3 # coding:utf-8 import socket from concurrent import futures from selecto

  • 详解python之异步编程

    目录 一.异步编程概述 二.python的异步框架模型 三.顺序执行多个可重叠的任务 四.异步化同步代码 五.使用多线程克服具体任务的异步限制 总结 一.异步编程概述 异步编程是一种并发编程的模式,其关注点是通过调度不同任务之间的执行和等待时间,通过减少处理器的闲置时间来达到减少整个程序的执行时间:异步编程跟同步编程模型最大的不同就是其任务的切换,当遇到一个需要等待长时间执行的任务的时候,我们可以切换到其他的任务执行: 与多线程和多进程编程模型相比,异步编程只是在同一个线程之内的的任务调度,无法

  • JavaScript异步编程操作实现介绍

    目录 异步编程 同步模式与异步模式 同步模式(Synchronous) 异步模式(Asynchronous) 回调函数 Promise Promise基本用法 Promise使用案例 Promise常见误区 Promise异常处理 Promise静态方法 宏任务与微任务 Generator 异步方案 生成器函数回顾 async与await 异步编程 目前主流的JavaScript执行环境都是以单线程执行JavaScript的. JavaScript早期只是一门负责在浏览器端执行的脚本语言,主要用

  • Java并发 CompletableFuture异步编程的实现

    前面我们不止一次提到,用多线程优化性能,其实不过就是将串行操作变成并行操作.如果仔细观察,你还会发现在串行转换成并行的过程中,一定会涉及到异步化,例如下面的示例代码,现在是串行的,为了提升性能,我们得把它们并行化. // 以下两个方法都是耗时操作 doBizA(); doBizB(); //创建两个子线程去执行就可以了,两个操作已经被异步化了. new Thread(()->doBizA()) .start(); new Thread(()->doBizB()) .start(); 异步化,是

  • Java 8 的异步编程利器 CompletableFuture的实例详解

    目录 一个例子回顾Future 一个例子走进CompletableFuture CompletableFuture使用场景 创建异步任务 supplyAsync方法 runAsync方法 任务异步回调 1.thenRun/thenRunAsync 2.thenAccept/thenAcceptAsync 3.thenApply/thenApplyAsync 4.exceptionally 5.whenComplete方法 6.handle方法 多个任务组合处理 AND组合关系 OR组合的关系 区

随机推荐