涉及到线程,就会存在阻塞和非阻塞、同步和异步。
阻塞和非阻塞
强调的是程序在等待调用结果(消息,返回值)时的状态. 阻塞调用是指调用结果返回之前,当前线程会被挂起。调用线程只有在得到结果之后才会返回。非阻塞调用指在不能立刻得到结果之前,该调用不会阻塞当前线程。 对于同步调用来说,很多时候当前线程还是激活的状态,只是从逻辑上当前函数没有返回而已,即同步等待时什么都不干,白白占用着资源。
同步和异步
强调的是消息通信机制 (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)