zoukankan      html  css  js  c++  java
  • two process type of Python

    multiprocessing -- python进程协同

    https://docs.python.org/3.7/library/multiprocessing.html

    multiprocessing is a package that supports spawning processes using an API similar to the threading module. The multiprocessing package offers both local and remote concurrency, effectively side-stepping the Global Interpreter Lock by using subprocesses instead of threads. Due to this, the multiprocessing module allows the programmer to fully leverage multiple processors on a given machine. It runs on both Unix and Windows.

    可以同一机器和不同机器上,进行进程协同。

    相同机器:

    from multiprocessing import Process
    import os
    
    def info(title):
        print(title)
        print('module name:', __name__)
        print('parent process:', os.getppid())
        print('process id:', os.getpid())
    
    def f(name):
        info('function f')
        print('hello', name)
    
    if __name__ == '__main__':
        info('main line')
        p = Process(target=f, args=('bob',))
        p.start()
        p.join()

    不同机器:

    from multiprocessing.connection import Listener
    from array import array
    
    address = ('localhost', 6000)     # family is deduced to be 'AF_INET'
    
    with Listener(address, authkey=b'secret password') as listener:
        with listener.accept() as conn:
            print('connection accepted from', listener.last_accepted)
    
            conn.send([2.25, None, 'junk', float])
    
            conn.send_bytes(b'hello')
    
            conn.send_bytes(array('i', [42, 1729]))
    from multiprocessing.connection import Client
    from array import array
    
    address = ('localhost', 6000)
    
    with Client(address, authkey=b'secret password') as conn:
        print(conn.recv())                  # => [2.25, None, 'junk', float]
    
        print(conn.recv_bytes())            # => 'hello'
    
        arr = array('i', [0, 0, 0, 0, 0])
        print(conn.recv_bytes_into(arr))    # => 8
        print(arr)                          # => array('i', [42, 1729, 0, 0, 0])

    subprocess -- call non python app

    https://docs.python.org/3.7/library/subprocess.html

    生成外部程序作为子进程,并获取执行其执行结果。

    The subprocess module allows you to spawn new processes, connect to their input/output/error pipes, and obtain their return codes. This module intends to replace several older modules and functions:

    The recommended approach to invoking subprocesses is to use the run() function for all use cases it can handle. For more advanced use cases, the underlying Popen interface can be used directly.

    https://pymotw.com/3/subprocess/index.html

    import subprocess
    
    completed = subprocess.run(
        ['ls', '-1'],
        stdout=subprocess.PIPE,
    )
    print('returncode:', completed.returncode)
    print('Have {} bytes in stdout:
    {}'.format(
        len(completed.stdout),
        completed.stdout.decode('utf-8'))
    )
  • 相关阅读:
    centos安装时各个版本的含义
    centos或者ubuntu设置ssh免密码登陆
    centos配置网卡
    如何卸载centos中自带的Java
    基于VHDL的8255可编程并行接口电路设计
    Norns.Urd 中的一些设计
    手把手教你写DI_3_小白徒手支持 `Singleton` 和 `Scoped` 生命周期
    手把手教你写DI_2_小白徒手撸构造函数注入
    手把手教你写DI_1_DI框架有什么?
    手把手教你写DI_0_DI是什么?
  • 原文地址:https://www.cnblogs.com/lightsong/p/14029544.html
Copyright © 2011-2022 走看看