摘要:项目地址中内置的库和分别提供了堆和优先队列结构,其中优先队列本身也是基于实现的,因此我们这次重点看一下。堆可以用于实现调度器例见之协程,更常用的是优先队列例如。
项目地址:https://git.io/pytips
Python 中内置的 heapq 库和 queue 分别提供了堆和优先队列结构,其中优先队列 queue.PriorityQueue 本身也是基于 heapq 实现的,因此我们这次重点看一下 heapq。
堆(Heap)是一种特殊形式的完全二叉树,其中父节点的值总是大于子节点,根据其性质,Python 中可以用一个满足 heap[k] <= heap[2*k+1] and heap[k] <= heap[2*k+2] 的列表来实现(heapq 也确实是这么做的)。堆可以用于实现调度器(例见:Python 3.5 之协程),更常用的是优先队列(例如:ImageColorTheme)。
heapq 提供了下面这些方法:
</>复制代码
import heapq
print(heapq.__all__)
</>复制代码
["heappush", "heappop", "heapify", "heapreplace", "merge", "nlargest", "nsmallest", "heappushpop"]
由于 Heap 是通过列表实现的,我们可以直接用列表创建:
</>复制代码
from heapq import *
heap = []
heappush(heap, 3)
heappush(heap, 2)
heappush(heap, 1)
print(heap)
</>复制代码
[1, 3, 2]
pop 或 sort 前要确保 heapify
或者通过 heapify 将普通列表转化为 Heap:
</>复制代码
heap = list(reversed(range(5)))
print("List: ", heap)
heapify(heap)
print("Heap: ", heap)
</>复制代码
List: [4, 3, 2, 1, 0]
Heap: [0, 1, 2, 4, 3]
每次从 Heap 中 pop 出来的元素都是最小的(因而可以据此实现堆排序):
</>复制代码
heap = [5,4,3,2,1]
heapify(heap)
print(heappop(heap))
print(heappop(heap))
print(heappop(heap))
优先队列</>复制代码
1
2
3
queue.PriorityQueue 实际上只是对 heapq 的简单封装,直接使用其 heappush/heappop 方法:
</>复制代码
from queue import PriorityQueue as PQueue
pq = PQueue()
pq.put((5 * -1, "Python"))
pq.put((4 * -1, "C"))
pq.put((3 * -1, "Js"))
print("Inside PriorityQueue: ", pq.queue) # 内部存储
while not pq.empty():
print(pq.get()[1])
</>复制代码
Inside PriorityQueue: [(-5, "Python"), (-4, "C"), (-3, "Js")]
Python
C
Js
由于 heapq 是最小堆,而通常 PriorityQueue 用在较大有限制的排前面,所以需要给 priority * -1。
sorted 一定是 Heap,反之未必需要注意的是,虽然 Heap 通过 List 实习,但未经过 heapify() 处理的仍然是一个普通的 List,而 heappush 和 heappop 操作每次都会对 Heap 进行重新整理。此外,一个 Heap 列表不一定是正确排序的,但是经过 list.sort() 的列表一定是 Heap:
</>复制代码
import random
lst = [random.randrange(1, 100) for _ in range(5)]
lst.sort()
print("List: ", lst)
print("Poped: ", heappop(lst))
heappush(lst, 4)
print("Heap: ", lst)
</>复制代码
List: [24, 55, 81, 83, 87]
Poped: 24
Heap: [4, 55, 81, 87, 83]
最大/最小的 N 个数
Heap 还提供了 nsmallest 和 nlargest 方法用于取出前 n 个最大/最小数:
</>复制代码
heap = [random.randrange(1, 1000) for _ in range(1000)]
heapify(heap)
print("N largest: ", nlargest(10, heap))
print("N smallest: ", nsmallest(10, heap))
print(len(heap)) # 不原地修改
</>复制代码
N largest: [999, 999, 998, 994, 992, 991, 990, 988, 985, 982]
N smallest: [1, 1, 1, 2, 4, 5, 5, 6, 6, 9]
1000
合并(排序)
merge 方法用于将两个 Heap 进行合并:
</>复制代码
heapA = sorted([random.randrange(1, 100) for _ in range(3)])
heapB = sorted([random.randrange(1, 100) for _ in range(3)])
merged = []
for i in merge(heapA, heapB):
merged.append(i)
print(merged)
</>复制代码
[5, 29, 66, 66, 70, 99]
最后两个方法 heapreplace 和 heappushpop 分别相当于:
</>复制代码
lstA = [1,2,3,4,5]
lstB = [1,2,3,4,5]
poped = heapreplace(lstA, 0)
print("lstA: ", lstA, "poped: ", poped)
# is equal to...
poped = heappop(lstB)
heappush(lstB, 0)
print("lstB: ", lstA, "poped: ", poped)
print("*"*30)
poped = heappushpop(lstA, 9)
print("lstA: ", lstA, "poped: ", poped)
# is equal to...
heappush(lstB, 9)
poped = heappop(lstB)
print("lstB: ", lstB, "poped: ", poped)
</>复制代码
lstA: [0, 2, 3, 4, 5] poped: 1
lstB: [0, 2, 3, 4, 5] poped: 1
******************************
lstA: [2, 4, 3, 9, 5] poped: 0
lstB: [2, 4, 3, 5, 9] poped: 0
这两个方法的执行效率要比分开写的方法高,但要注意 heapreplace 要取代的值是否比 heap[0] 大,如果不是,可以用更有效的方法:
</>复制代码
item = 0
lstA = [1,2,3,4,5]
if item < lstA[0]:
# replace
poped = lstA[0]
lstA[0] = item
print("lstA: ", lstA, "poped: ", poped)
</>复制代码
lstA: [0, 2, 3, 4, 5] poped: 1
欢迎关注公众号 PyHub!
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/37859.html
摘要:一个常见的例子就是优先队列,还有排序算法之一的堆排序。另外我们还将学习堆排序,并将使用实现堆。堆排序在堆排序中,我们需要用给定的值构建一个一个堆。伪代码如下从上面的伪代码可以看到,堆排序的第一步就是构建一个堆。 堆是什么? 堆是基于树抽象数据类型的一种特殊的数据结构,用于许多算法和数据结构中。一个常见的例子就是优先队列,还有排序算法之一的堆排序。这篇文章我们将讨论堆的属性、不同类型的堆...
摘要:项目地址我之前翻译了协程原理这篇文章之后尝试用了模式下的协程进行异步开发,确实感受到协程所带来的好处至少是语法上的。 项目地址:https://git.io/pytips 我之前翻译了Python 3.5 协程原理这篇文章之后尝试用了 Tornado + Motor 模式下的协程进行异步开发,确实感受到协程所带来的好处(至少是语法上的:D)。至于协程的 async/await 语法是如...
摘要:这里的关键词函数必须明确指明,不能通过位置推断则代表任意数量的关键词参数添加的新特性,使得可以在函数参数之外使用这里的逗号不能漏掉所谓的解包实际上可以看做是去掉的元组或者是去掉的字典。 项目地址:https://git.io/pytips 函数调用的参数规则与解包 Python 的函数在声明参数时大概有下面 4 种形式: 不带默认值的:def func(a): pass 带有默认值的...
摘要:中关于线程的标准库是,之前在版本中的在之后更名为,无论是还是都应该尽量避免使用较为底层的而应该使用。而与线程相比,协程尤其是结合事件循环无论在编程模型还是语法上,看起来都是非常友好的单线程同步过程。 项目地址:https://git.io/pytips 要说到线程(Thread)与协程(Coroutine)似乎总是需要从并行(Parallelism)与并发(Concurrency)谈起...
阅读 1706·2021-11-23 10:07
阅读 2705·2019-08-30 11:10
阅读 2884·2019-08-29 17:08
阅读 1831·2019-08-29 15:42
阅读 3224·2019-08-29 12:57
阅读 2440·2019-08-28 18:06
阅读 3593·2019-08-27 10:56
阅读 427·2019-08-26 11:33