Python之进程+线程+协程（同步对象、信号量、队列）

文章目录

Event同步对象
semaphore信号量
队列

本篇是关于Python进程方面的内容了，主要是Event同步对象，信号量和队列

Event同步对象

1、概念：
我们可以对一个线程set一个值来等待，在等待期间，其他线程都不能继续往下执行，直到这个值被clear，其他的线程才能接着往下执行

就比如考试，监考老师进入教室，一群学生开始考试；
然后只有老师说停笔，你才能够走出考场；
即使你卷子已经做完了，也得等着老师的通知才能离开。

2、测试代码：

import threading,time#老师类
class Teacher(threading.Thread):def run(self):print("老师：开始考试，今天考到12：30！")print(event.isSet())  #查看是否有设置值#开始设置值event.set()  time.sleep(5)  #设置标准考试时间为5秒钟#老师的动作print("老师：12：30到了，考试结束！")#老师的动作结束了，所以再次查看是否设置了值还是Falseprint(event.isSet())  #再次查看是否设置了值event.set()#学生类
class Student(threading.Thread):def run(self):event.wait()print("学生：唉，开考了......")time.sleep(1)  #假设学生考试只花1秒中event.clear()  #清除event.wait()print("学生：终于考完了......")if __name__=="__main__":#实例化一个Event对象event=threading.Event()L= []for i in range(5):L.append(Student())L.append(Teacher())#启动线程for t in L:t.start()for t in L:t.join()

3、测试结果：

可以看到，几个学生同时开考，等老师这个任务结束后，这群学生才可以结束

semaphore信号量

1、引用概念：

信号量用来控制可以同时开启线程的个数，BoundedSemaphore或Semaphore管理一个内置的计数器，每当调用acquire()时-1，调用release()时+1。

计数器不能小于0，当计数器为 0时，acquire()将阻塞线程至同步锁定状态，直到其他线程调用release()。(类似于停车位的概念)

BoundedSemaphore与Semaphore的唯一区别在于前者将在调用release()时检查计数器的值是否超过了计数器的初始值，如果超过了将抛出一个异常。

2、测试代码：

import threading,time#继承线程的类
class MyThread(threading.Thread):def run(self):if semaphore.acquire():print(self.name)  #输出线程名time.sleep(5)  #睡5秒，每一个线程都会停留5秒#释放信号量semaphore.release() if __name__=="__main__":#设置信号量，为5表明可以一次性执行的线程是5个semaphore=threading.Semaphore(5)L= []for i in range(100):L.append(MyThread())for t in L:  #启动线程t.start()

3、测试结果：

可以看到，线程每五个五个得出来

队列

1、先进先出型：

import queue  #导入线程队列L= []#创建线程队列对象
q= queue.Queue(5)
#能装5个对象的队列(不指定，则任意大小)，block=False表示队列满了会提示错误信息#在线程队列放入值
q.put([1,233333])
q.put([2,'little girl'])
q.put([3,{'name':'初音'}])
#q.put({'name2':'初音2'})#取值
while True:data= q.get(block=True)#block=False表示如果卡住了会提示错误,#因为该线程队列已经没有数据可以取了，所以会提示队列空的信息print(data,'------')

2、先进后出型：

import queue#后进先出队列
q= queue.LifoQueue()#在线程队列放入值
q.put([1,233333])
q.put([2,'little girl'])
q.put([3,{'name':'初音'}])#取值
while True:data= q.get(block=False)#block=False表示如果卡住了会提示错误,#因为该线程队列已经没有数据可以取了，所以会提示队列空的信息print(data,'-----')队列的其他方法
import queue#创建队列
q= queue.Queue()#在线程队列放入值
q.put([1,233333])
q.put([2,'little girl'])
q.put([3,{'name':'初音'}])#取值
print(q.qsize())  #队列值的个数
print(q.empty())  #是否为空
print(q.full())  #是否满
q.task_done()

Python之进程+线程+协程（同步对象、信号量、队列）相关推荐

Python之进程+线程+协程（异步、selectors模块、阻塞、非阻塞IO）
文章目录一.IO多路复用二.selectors模块本篇文字是关于IO多路复用的更深入一步的总结,上一篇 Python之进程+线程+协程(事件驱动模型.IO多路复用.select与epoll)对I ...
Python之进程+线程+协程（并发与并行、GIL锁、同步锁、死锁、递归锁）
文章目录一.并发与并行二.同步与异步三.线程锁 1.GIL全局解释器锁 2.同步锁 3.死锁 4.递归锁在Python中GIL解释器锁.同步锁.死锁.递归锁都是什么?怎么这么多锁,它们都是用来 ...
Python之进程+线程+协程（事件驱动模型、IO多路复用、select与epoll）
文章目录一.事件驱动模型二.IO多路复用本篇文章是关于涉及网络编程与协程.进程之间结合的内容,其中事件驱动模型.IO多路复用.select与epoll的使用等方面的知识一.事件驱动模型 1.事 ...
Python之进程+线程+协程（multiprocessing多进程模块）
前几篇的多线程模块的各种规则和用法,本篇则是关于多进程模块的内容 1.multiprocessing的介绍在Python中,由于有GIL解释器锁的存在,多线程就根本不是本质意义上的多线程,而是一个主 ...
Python之进程+线程+协程（进程的本质与 threading线程模块）
文章目录基本概念 threading线程模块本篇开始分析Python中的并发程序,也就是进程.线程.协程序的使用.由于是用自己的语言总结的,因此比较大白话,或者叫通俗易懂.而且很多细节方面没有具体 ...
Python之进程+线程+协程（进程间通信、进程同步、进程池、回调函数）
文章目录进程间通信进程同步进程池回调函数本篇文章依然是进程.线程方面的内容,主要讲进程间的通信.进程队列.进程同步.进程池.进程同步和回调函数进程间通信进程就是两个独立的内存空间在运行, ...
Python之进程+线程+协程（生产者消费者模型）
本篇主要总结一下非常有名的生成者消费者模型概念引用 1.为什么要使用生产者和消费者模型? 在线程世界里,生产者就是生产数据的线程,消费者就是消费数据的线程.在多线程开发当中,如果生产者处理速度很快, ...
linux的进程/线程/协程系列5：协程的发展复兴与实现现状
协程的发展复兴与实现现状前言本篇摘要: 1. 协同制的发展史 1.1 协同工作制的提出 1.2 自顶向下,无需协同 1.3 协同式思想的应用 2. 协程的复兴 2.1 高并发带来的问题 2.2 制 ...
Linux的进程/线程/协程系列4：进程知识深入总结：上篇
Linux的进程/线程/协程系列4:进程/线程相关知识总结前言本篇摘要: 1. 进程基础知识 1.1 串行/并行与并发 1.2 临界资源与共享资源 1.3 同步/异步与互斥 1.4 进程控制原语 ...

Python之进程+线程+协程（同步对象、信号量、队列）

文章目录

Event同步对象

semaphore信号量

队列

Python之进程+线程+协程（同步对象、信号量、队列）相关推荐

最新文章

热门文章