python-threading多线程理解与应用

涉及到线程，就会存在阻塞和非阻塞、同步和异步。

阻塞和非阻塞
强调的是程序在等待调用结果（消息，返回值）时的状态. 阻塞调用是指调用结果返回之前，当前线程会被挂起。调用线程只有在得到结果之后才会返回。非阻塞调用指在不能立刻得到结果之前，该调用不会阻塞当前线程。 对于同步调用来说，很多时候当前线程还是激活的状态，只是从逻辑上当前函数没有返回而已，即同步等待时什么都不干，白白占用着资源。

同步和异步
强调的是消息通信机制 (synchronous communication/ asynchronous communication)。所谓同步，就是在发出一个"调用"时，在没有得到结果之前，该“调用”就不返回。但是一旦调用返回，就得到返回值了。换句话说，就是由“调用者”主动等待这个“调用”的结果。而异步则是相反，"调用"在发出之后，这个调用就直接返回了，所以没有返回结果。换句话说，当一个异步过程调用发出后，调用者不会立刻得到结果。而是在"调用"发出后，"被调用者"通过状态、通知来通知调用者，或通过回调函数处理这个调用

参考博客：https://blog.csdn.net/huangqiang1363/article/details/79508852

实际应用场景：
python-locust单机分布式压测。
当locust以分布式运行启动master主机后，线程是阻塞的，会等待n个worker链接。要实现的最终效果为用subprocess.Popen先启动master主机，接着启动n个worker。这样就不需要每次都打开三四五六七八个终端窗口来启动n个worker，具体实现代码如下：

#入参worker默认为1，运行一个master，一个worker
def demo(worker=1):
    master_worker = ['master']
    for num in range(worker):
        master_worker.append("worker")
    start_worker_number = worker
    worker_num = -1
    for i in master_worker:
        worker_num += 1
        if i == 'master' :
            #创建master线程
            t = threading.Thread(target=LocustThreading(locust=i, num=start_worker_number).create_tread)
            t.start() #启动 master，不能用join()方法，否则会阻塞，不会启动worker
            time.sleep(3)
        else:
            #创建worker线程
            t = threading.Thread(target=LocustThreading(locust=i, num=worker_num).create_tread)
            t.start() #启动 worker
            time.sleep(2)