Nota

¡Ayúdanos a traducir la documentación oficial de Python al Español! Puedes encontrar más información en Como contribuir. Ayuda a acercar Python a más personas de habla hispana.

Ejecución concurrente

Los módulos descritos en este capítulo proveen soporte para la ejecución concurrente de código. La elección de qué herramienta utilizar depende de la tarea a ejecutar (vinculada a CPU o vinculada a E/S) y del estilo preferido de desarrollo (multi-tarea cooperativa o multi-tarea apropiativa). A continuación se muestra un resumen:

• threading — Paralelismo basado en hilos
  • 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
  • Datos locales del hilo
    • local
  • Objetos tipo hilo
    • 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()
  • Objetos tipo lock
    • Lock
      • Lock.acquire()
      • Lock.release()
      • Lock.locked()
  • Objetos Rlock
    • RLock
      • RLock.acquire()
      • RLock.release()
  • Objetos condicionales
    • Condition
      • Condition.acquire()
      • Condition.release()
      • Condition.wait()
      • Condition.wait_for()
      • Condition.notify()
      • Condition.notify_all()
  • Objetos semáforo
    • Semaphore
      • Semaphore.acquire()
      • Semaphore.release()
    • BoundedSemaphore
    • Ejemplo de Semaphore
  • Objetos de eventos
    • Event
      • Event.is_set()
      • Event.set()
      • Event.clear()
      • Event.wait()
  • Objetos temporizadores
    • Timer
      • Timer.cancel()
  • Objetos de barrera
    • Barrier
      • Barrier.wait()
      • Barrier.reset()
      • Barrier.abort()
      • Barrier.parties
      • Barrier.n_waiting
      • Barrier.broken
    • BrokenBarrierError
  • Uso de locks, condiciones y semáforos en la declaración with
• multiprocessing — Paralelismo basado en procesos
  • Introducción
    • La clase Process
    • Contextos y métodos de inicio
    • Intercambiando objetos entre procesos
    • Sincronización entre procesos
    • Compartiendo estado entre procesos
    • Usando una piscina de trabajadores (pool of workers)
  • Referencia
    • Process y excepciones
      • 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
    • Tuberías (Pipes) y Colas (Queues)
      • 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()
    • Miscelánea
      • 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()
    • Objetos de conexión Connection Objects
      • Connection
        • Connection.send()
        • Connection.recv()
        • Connection.fileno()
        • Connection.close()
        • Connection.poll()
        • Connection.send_bytes()
        • Connection.recv_bytes()
        • Connection.recv_bytes_into()
    • Primitivas de sincronización (Synchronization primitives)
      • Barrier
      • BoundedSemaphore
      • Condition
      • Event
      • Lock
        • Lock.acquire()
        • Lock.release()
      • RLock
        • RLock.acquire()
        • RLock.release()
      • Semaphore
    • Objetos compartidos ctypes
      • Value()
      • Array()
      • El módulo multiprocessing.sharedctypes
        • RawArray()
        • RawValue()
        • Array()
        • Value()
        • copy()
        • synchronized()
    • Administradores (Managers)
      • 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
      • Administradores customizables (Customized managers)
      • Utilizando un administrador remoto
    • Objetos Proxy (Proxy Objects)
      • BaseProxy
        • BaseProxy._callmethod()
        • BaseProxy._getvalue()
        • BaseProxy.__repr__()
        • BaseProxy.__str__()
      • Limpieza (Cleanup)
    • Piscinas de procesos (Process Pools)
      • 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()
    • Oyentes y clientes (Listeners and Clients)
      • deliver_challenge()
      • answer_challenge()
      • Client()
      • Listener
        • Listener.accept()
        • Listener.close()
        • Listener.address
        • Listener.last_accepted
      • wait()
      • Formatos de dirección (Address formats)
    • Llaves de autentificación
    • Logging
      • get_logger()
      • log_to_stderr()
    • El módulo multiprocessing.dummy
      • ThreadPool
  • Pautas de programación
    • Todos los métodos de inicio
    • Los métodos de inicio spawn y forkserver
  • Ejemplos
• multiprocessing.shared_memory — Memoria compartida para acceso directo a través de procesos
  • 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
• El paquete concurrent
• concurrent.futures — Lanzamiento de tareas paralelas
  • Objetos ejecutores
    • Executor
      • Executor.submit()
      • Executor.map()
      • Executor.shutdown()
  • ThreadPoolExecutor
    • ThreadPoolExecutor
    • Ejemplo de ThreadPoolExecutor
  • ProcessPoolExecutor
    • ProcessPoolExecutor
    • Ejemplo de ProcessPoolExecutor
  • Objetos futuro
    • 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()
  • Funciones del módulo
    • wait()
    • as_completed()
  • Clases de Excepciones
    • CancelledError
    • TimeoutError
    • BrokenExecutor
    • InvalidStateError
    • BrokenThreadPool
    • BrokenProcessPool
• subprocess — Gestión de subprocesos
  • Uso del módulo 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
    • Argumentos frecuentemente empleados
    • El constructor de Popen
      • Popen
    • Excepciones
  • Consideraciones sobre seguridad
  • Objetos 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
  • Elementos auxiliares de Popen en Windows
    • STARTUPINFO
      • STARTUPINFO.dwFlags
      • STARTUPINFO.hStdInput
      • STARTUPINFO.hStdOutput
      • STARTUPINFO.hStdError
      • STARTUPINFO.wShowWindow
      • STARTUPINFO.lpAttributeList
    • Constantes de 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
  • Antigua API de alto nivel
    • call()
    • check_call()
    • check_output()
  • Cómo reemplazar anteriores funciones con el módulo subprocess
    • Cómo reemplazar la sustitución de órdenes de /bin/sh
    • Cómo remplazar los flujos de la shell
    • Cómo reemplazar os.system()
    • Cómo reemplazar la familia os.spawn
    • Cómo reemplazar os.popen(), os.popen2(), os.popen3()
    • Cómo reemplazar las funciones del módulo popen2
  • Funciones de llamada a la shell de retrocompatibilidad
    • getstatusoutput()
    • getoutput()
  • Notas
    • Cómo convertir una secuencia de argumentos a una cadena en Windows
    • Deshabilitar el uso de vfork() o posix_spawn()
• sched — Eventos del planificador
  • scheduler
  • Objetos de Scheduler
    • scheduler.enterabs()
    • scheduler.enter()
    • scheduler.cancel()
    • scheduler.empty()
    • scheduler.run()
    • scheduler.queue
• queue — clase de cola sincronizada
  • Queue
  • LifoQueue
  • PriorityQueue
  • SimpleQueue
  • Empty
  • Full
  • Objetos de la cola
    • Queue.qsize()
    • Queue.empty()
    • Queue.full()
    • Queue.put()
    • Queue.put_nowait()
    • Queue.get()
    • Queue.get_nowait()
    • Queue.task_done()
    • Queue.join()
  • Objetos de cola simple
    • SimpleQueue.qsize()
    • SimpleQueue.empty()
    • SimpleQueue.put()
    • SimpleQueue.put_nowait()
    • SimpleQueue.get()
    • SimpleQueue.get_nowait()
• contextvars — Variables de Contexto
  • variables de contexto
    • ContextVar
      • ContextVar.name
      • ContextVar.get()
      • ContextVar.set()
      • ContextVar.reset()
    • Token
      • Token.var
      • Token.old_value
      • Token.MISSING
  • Gestión de contexto manual
    • copy_context()
    • Context
      • Context.run()
      • Context.copy()
      • Context.get()
      • Context.keys()
      • Context.values()
      • Context.items()
  • Soporte asyncio

He aquí módulos de apoyo para algunos de los servicios mencionados:

• _thread — API de bajo nivel para manejo de hilos
  • 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()