基于event 实现的线程安全的优先队列(python实现)

event 事件是个很不错的线程同步，以及线程通信的机制，在python的许多源代码中都基于event实现了很多的线程安全，支持并发，线程通信的库

对于优先队列的堆实现，请看《python下实现二叉堆以及堆排序》, python的event请看<python lock, semaphore, event实现线程同步>, 其实主要注意event几个方法的用法, 以及多线程访问下的程序的逻辑顺序, 在相关代码段放好event的几个方法就好了。自己去理解下, 不难。看下源码吧：

import heapq
import threading
# import timeclass Item:def __init__(self, name):self.name = namedef __repr__(self):return 'Item({!r})'.format(self.name)class PriorityQueue:def __init__(self):self._queue = []self._index = 0self._event = threading.Event()def push(self, item, priority):if len(self._queue) != 0:self._event.clear()while not self._event.is_set():self._event.set()heapq.heappush(self._queue, (-priority, self._index, item))  # 存入一个三元组, 默认构造的是小顶堆self._index += 1# self._event.set()def pop(self):if len(self._queue) != 0:self._event.set()while self._event.is_set():self._event.wait()x = heapq.heappop(self._queue)[-1]  # 逆序输出
            self._event.clear()return xdef test1(p, item, index):for i in range(3):p.push(Item(item), index)def test2(p):for i in range(3):print(p.pop())if __name__ == '__main__':p = PriorityQueue()t1 = threading.Thread(target=test1, args=(p, 'foo', 1))t3 = threading.Thread(target=test1, args=(p, 'bar', 2))t4 = threading.Thread(target=test1, args=(p, 'Ryan', 28))t2 = threading.Thread(target=test2, args=(p,))t5 = threading.Thread(target=test2, args=(p,))t6 = threading.Thread(target=test2, args=(p,))t1.start()t2.start()t1.join()t2.join()t3.start()t5.start()t3.join()t5.join()t4.start()t6.start()t4.join()t6.join()

建议去看看python的socket源码以及queue.py等源码这些涉及到了多线程访问的库都是基于这些线程同步机制实现的, 你可以仿写下, 毕竟人家写的更专业.

转载于:https://www.cnblogs.com/zhiyong-ITNote/p/7629010.html

基于event 实现的线程安全的优先队列(python实现)相关推荐

安全云盘项目（二）：2.1 基于libevent的C++线程池
注意:基于libevent的C++线程池主要参数memcached 下图是具体的技术栈项目功能: 1.实现ftp服务器,在linux种和windows种都可以运行 2.实现ftp的基本功能 (1)匿 ...
python queue死锁_Python学习【第24篇】：死锁，递归锁，信号量，Event事件，线程Queue...
一.死锁现象与递归锁进程也是有死锁的所谓死锁: 是指两个或两个以上的进程或线程在执行过程中,因争夺资源而造成的一种互相等待的现象,若无外力作用, 它们都将无法推进下去.此时称系统处于死锁状态或系统 ...
连傻瓜都能看懂的基于代码注入的线程守护技术
连傻瓜都能看懂的基于代码注入的线程守护技术 2010年08月31日连傻瓜都能看懂的基于代码注入的线程守护技术 Author: 叶紫孤(CPP肥兔) (感谢冷风大哥提供技术支持) E-mail: ye ...
【C++学习】基于Linux/C++简单线程池的实现
[C++学习] 基于Linux/C++简单线程池的实现转载自:https://www.cnblogs.com/alwayswangzi/p/7138154.html 我们知道Java语言对于多线程的 ...
Python 线程池 ThreadPoolExecutor(二) - Python零基础入门教程
目录一.Python 线程池前言二.Python 线程池 ThreadPoolExecutor 常用函数 1.线程池 as_completed 函数使用 2.线程池 map 函数使用 3.线程池 ...
Python 线程池 ThreadPoolExecutor(一) - Python零基础入门教程
目录一.Python 线程池前言二.Python 线程池原理三.Python 线程池 ThreadPoolExecutor 函数介绍四.Python 线程池 ThreadPoolExecuto ...
Python 线程队列 LifoQueue – LIFO - Python零基础入门教程
目录一.Python 线程队列 Queue 分类二.Python 线程先进后出队列 LifoQueue 简介三.Python 线程先进后出队列 LifoQueue 函数介绍四.Python 线 ...
Python 线程队列 Queue – FIFO - Python零基础入门教程
目录一.Python 线程队列分类二.Python 线程先进先出队列 Queue 简介三.Python 线程先进先出队列 Queue 常用函数四.Python 线程先进先出队列 Queue 使 ...
Python 线程障碍对象 Barrier - Python零基础入门教程
目录一.Python 线程障碍对象 Barrier 简介二.Python 线程障碍对象 Barrier 原理三.Python 线程障碍对象 Barrier 函数介绍四.Python 线程障碍对 ...

基于event 实现的线程安全的优先队列(python实现)

基于event 实现的线程安全的优先队列(python实现)相关推荐

最新文章

热门文章