并发执行

本章中描述的模块支持并发执行代码。 适当的工具选择取决于要执行的任务（CPU密集型或IO密集型）和偏好的开发风格（事件驱动的协作式多任务或抢占式多任务处理）。 这是一个概述：

• threading --- 基于线程的并行
  • active_count()
  • current_thread()
  • excepthook()
  • __excepthook__
  • get_ident()
  • get_native_id()
  • enumerate()
  • main_thread()
  • settrace()
  • settrace_all_threads()
  • gettrace()
  • setprofile()
  • setprofile_all_threads()
  • getprofile()
  • stack_size()
  • TIMEOUT_MAX
  • 线程本地数据
    • local
  • 线程对象
    • Thread
      • Thread.start()
      • Thread.run()
      • Thread.join()
      • Thread.name
      • Thread.getName()
      • Thread.setName()
      • Thread.ident
      • Thread.native_id
      • Thread.is_alive()
      • Thread.daemon
      • Thread.isDaemon()
      • Thread.setDaemon()
  • 锁对象
    • Lock
      • Lock.acquire()
      • Lock.release()
      • Lock.locked()
  • 递归锁对象
    • RLock
      • RLock.acquire()
      • RLock.release()
  • 条件对象
    • Condition
      • Condition.acquire()
      • Condition.release()
      • Condition.wait()
      • Condition.wait_for()
      • Condition.notify()
      • Condition.notify_all()
  • 信号量对象
    • Semaphore
      • Semaphore.acquire()
      • Semaphore.release()
    • BoundedSemaphore
    • Semaphore 例子
  • 事件对象
    • Event
      • Event.is_set()
      • Event.set()
      • Event.clear()
      • Event.wait()
  • 定时器对象
    • Timer
      • Timer.cancel()
  • 栅栏对象
    • Barrier
      • Barrier.wait()
      • Barrier.reset()
      • Barrier.abort()
      • Barrier.parties
      • Barrier.n_waiting
      • Barrier.broken
    • BrokenBarrierError
  • 在 with 语句中使用锁、条件和信号量
• multiprocessing --- 基于进程的并行
  • 概述
    • Process 类
    • 上下文和启动方法
    • 在进程之间交换对象
    • 进程间同步
    • 进程间共享状态
    • 使用工作进程
  • 参考
    • Process 和异常
      • Process
        • Process.run()
        • Process.start()
        • Process.join()
        • Process.name
        • Process.is_alive()
        • Process.daemon
        • Process.pid
        • Process.exitcode
        • Process.authkey
        • Process.sentinel
        • Process.terminate()
        • Process.kill()
        • Process.close()
      • ProcessError
      • BufferTooShort
      • AuthenticationError
      • TimeoutError
    • 管道和队列
      • Pipe()
      • Queue
        • Queue.qsize()
        • Queue.empty()
        • Queue.full()
        • Queue.put()
        • Queue.put_nowait()
        • Queue.get()
        • Queue.get_nowait()
        • Queue.close()
        • Queue.join_thread()
        • Queue.cancel_join_thread()
      • SimpleQueue
        • SimpleQueue.close()
        • SimpleQueue.empty()
        • SimpleQueue.get()
        • SimpleQueue.put()
      • JoinableQueue
        • JoinableQueue.task_done()
        • JoinableQueue.join()
    • 杂项
      • active_children()
      • cpu_count()
      • current_process()
      • parent_process()
      • freeze_support()
      • get_all_start_methods()
      • get_context()
      • get_start_method()
      • set_executable()
      • set_forkserver_preload()
      • set_start_method()
    • 连接对象（Connection）
      • Connection
        • Connection.send()
        • Connection.recv()
        • Connection.fileno()
        • Connection.close()
        • Connection.poll()
        • Connection.send_bytes()
        • Connection.recv_bytes()
        • Connection.recv_bytes_into()
    • 同步原语
      • Barrier
      • BoundedSemaphore
      • Condition
      • Event
      • Lock
        • Lock.acquire()
        • Lock.release()
      • RLock
        • RLock.acquire()
        • RLock.release()
      • Semaphore
    • 共享 ctypes 对象
      • Value()
      • Array()
      • multiprocessing.sharedctypes 模块
        • RawArray()
        • RawValue()
        • Array()
        • Value()
        • copy()
        • synchronized()
    • 管理器
      • multiprocessing.Manager()
      • BaseManager
        • BaseManager.start()
        • BaseManager.get_server()
        • BaseManager.connect()
        • BaseManager.shutdown()
        • BaseManager.register()
        • BaseManager.address
      • SyncManager
        • SyncManager.Barrier()
        • SyncManager.BoundedSemaphore()
        • SyncManager.Condition()
        • SyncManager.Event()
        • SyncManager.Lock()
        • SyncManager.Namespace()
        • SyncManager.Queue()
        • SyncManager.RLock()
        • SyncManager.Semaphore()
        • SyncManager.Array()
        • SyncManager.Value()
        • SyncManager.dict()
        • SyncManager.list()
      • Namespace
      • 自定义管理器
      • 使用远程管理器
    • 代理对象
      • BaseProxy
        • BaseProxy._callmethod()
        • BaseProxy._getvalue()
        • BaseProxy.__repr__()
        • BaseProxy.__str__()
      • 清理
    • 进程池
      • Pool
        • Pool.apply()
        • Pool.apply_async()
        • Pool.map()
        • Pool.map_async()
        • Pool.imap()
        • Pool.imap_unordered()
        • Pool.starmap()
        • Pool.starmap_async()
        • Pool.close()
        • Pool.terminate()
        • Pool.join()
      • AsyncResult
        • AsyncResult.get()
        • AsyncResult.wait()
        • AsyncResult.ready()
        • AsyncResult.successful()
    • 监听器及客户端
      • deliver_challenge()
      • answer_challenge()
      • Client()
      • Listener
        • Listener.accept()
        • Listener.close()
        • Listener.address
        • Listener.last_accepted
      • wait()
      • 地址格式
    • 认证密码
    • 日志记录
      • get_logger()
      • log_to_stderr()
    • multiprocessing.dummy 模块
      • ThreadPool
  • 编程指导
    • 所有start方法
    • spawn 和 forkserver 启动方式
  • 例子
• multiprocessing.shared_memory --- 可跨进程直接访问的共享内存
  • SharedMemory
    • SharedMemory.close()
    • SharedMemory.unlink()
    • SharedMemory.buf
    • SharedMemory.name
    • SharedMemory.size
  • SharedMemoryManager
    • SharedMemoryManager.SharedMemory()
    • SharedMemoryManager.ShareableList()
  • ShareableList
    • ShareableList.count()
    • ShareableList.index()
    • ShareableList.format
    • ShareableList.shm
• The concurrent package
• concurrent.futures --- 启动并行任务
  • Executor 对象
    • Executor
      • Executor.submit()
      • Executor.map()
      • Executor.shutdown()
  • ThreadPoolExecutor
    • ThreadPoolExecutor
    • ThreadPoolExecutor 例子
  • ProcessPoolExecutor
    • ProcessPoolExecutor
    • ProcessPoolExecutor 例子
  • Future 对象
    • Future
      • Future.cancel()
      • Future.cancelled()
      • Future.running()
      • Future.done()
      • Future.result()
      • Future.exception()
      • Future.add_done_callback()
      • Future.set_running_or_notify_cancel()
      • Future.set_result()
      • Future.set_exception()
  • 模块函数
    • wait()
    • as_completed()
  • Exception 类
    • CancelledError
    • TimeoutError
    • BrokenExecutor
    • InvalidStateError
    • BrokenThreadPool
    • BrokenProcessPool
• subprocess --- 子进程管理
  • 使用 subprocess 模块
    • run()
    • CompletedProcess
      • CompletedProcess.args
      • CompletedProcess.returncode
      • CompletedProcess.stdout
      • CompletedProcess.stderr
      • CompletedProcess.check_returncode()
    • DEVNULL
    • PIPE
    • STDOUT
    • SubprocessError
    • TimeoutExpired
      • TimeoutExpired.cmd
      • TimeoutExpired.timeout
      • TimeoutExpired.output
      • TimeoutExpired.stdout
      • TimeoutExpired.stderr
    • CalledProcessError
      • CalledProcessError.returncode
      • CalledProcessError.cmd
      • CalledProcessError.output
      • CalledProcessError.stdout
      • CalledProcessError.stderr
    • 常用参数
    • Popen 构造函数
      • Popen
    • 异常
  • 安全考量
  • Popen 对象
    • Popen.poll()
    • Popen.wait()
    • Popen.communicate()
    • Popen.send_signal()
    • Popen.terminate()
    • Popen.kill()
    • Popen.args
    • Popen.stdin
    • Popen.stdout
    • Popen.stderr
    • Popen.pid
    • Popen.returncode
  • Windows Popen 助手
    • STARTUPINFO
      • STARTUPINFO.dwFlags
      • STARTUPINFO.hStdInput
      • STARTUPINFO.hStdOutput
      • STARTUPINFO.hStdError
      • STARTUPINFO.wShowWindow
      • STARTUPINFO.lpAttributeList
    • Windows 常数
      • STD_INPUT_HANDLE
      • STD_OUTPUT_HANDLE
      • STD_ERROR_HANDLE
      • SW_HIDE
      • STARTF_USESTDHANDLES
      • STARTF_USESHOWWINDOW
      • CREATE_NEW_CONSOLE
      • CREATE_NEW_PROCESS_GROUP
      • ABOVE_NORMAL_PRIORITY_CLASS
      • BELOW_NORMAL_PRIORITY_CLASS
      • HIGH_PRIORITY_CLASS
      • IDLE_PRIORITY_CLASS
      • NORMAL_PRIORITY_CLASS
      • REALTIME_PRIORITY_CLASS
      • CREATE_NO_WINDOW
      • DETACHED_PROCESS
      • CREATE_DEFAULT_ERROR_MODE
      • CREATE_BREAKAWAY_FROM_JOB
  • 较旧的高阶 API
    • call()
    • check_call()
    • check_output()
  • 使用 subprocess 模块替换旧函数
    • 替代 /bin/sh shell 命令替换
    • 替代 shell 管道
    • 替代 os.system()
    • 替代 os.spawn 函数族
    • 替代 os.popen(), os.popen2(), os.popen3()
    • 来自 popen2 模块的替代函数
  • 旧式的 Shell 发起函数
    • getstatusoutput()
    • getoutput()
  • 备注
    • 在 Windows 上将参数列表转换为一个字符串
    • 禁用 vfork() 或 posix_spawn()
• sched --- 事件调度器
  • scheduler
  • 调度器对象
    • scheduler.enterabs()
    • scheduler.enter()
    • scheduler.cancel()
    • scheduler.empty()
    • scheduler.run()
    • scheduler.queue
• queue --- 一个同步的队列类
  • Queue
  • LifoQueue
  • PriorityQueue
  • SimpleQueue
  • Empty
  • Full
  • Queue对象
    • Queue.qsize()
    • Queue.empty()
    • Queue.full()
    • Queue.put()
    • Queue.put_nowait()
    • Queue.get()
    • Queue.get_nowait()
    • Queue.task_done()
    • Queue.join()
  • SimpleQueue 对象
    • SimpleQueue.qsize()
    • SimpleQueue.empty()
    • SimpleQueue.put()
    • SimpleQueue.put_nowait()
    • SimpleQueue.get()
    • SimpleQueue.get_nowait()
• contextvars --- 上下文变量
  • 上下文变量
    • ContextVar
      • ContextVar.name
      • ContextVar.get()
      • ContextVar.set()
      • ContextVar.reset()
    • Token
      • Token.var
      • Token.old_value
      • Token.MISSING
  • 手动上下文管理
    • copy_context()
    • Context
      • Context.run()
      • Context.copy()
      • Context.get()
      • Context.keys()
      • Context.values()
      • Context.items()
  • asyncio 支持

以下是上述某些服务的支持模块：

• _thread --- 底层多线程 API
  • error
  • LockType
  • start_new_thread()
  • interrupt_main()
  • exit()
  • allocate_lock()
  • get_ident()
  • get_native_id()
  • stack_size()
  • TIMEOUT_MAX
  • lock.acquire()
  • lock.release()
  • lock.locked()