【发布时间】:2017-03-17 15:21:19
【问题描述】:
我有一个获取过滤器存储中两个对象之一的请求,如下所示:
req = yield depot.get(lambda req: req['id'] == 's38' or 's39')
我想将此特定请求设为优先级,以便它排队跳过所有其他请求。这可能吗?
【问题讨论】:
我有一个获取过滤器存储中两个对象之一的请求,如下所示:
req = yield depot.get(lambda req: req['id'] == 's38' or 's39')
我想将此特定请求设为优先级,以便它排队跳过所有其他请求。这可能吗?
【问题讨论】:
是的,如果您创建类似于 PriorityQueue 的 FilterStore 子类,这是可能的。
【讨论】:
这是一个对我有用的例子
import simpy
import bisect
class PriorityFilterStore(simpy.FilterStore):
def _do_put(self, event):
if len(self.items) < self._capacity:
bisect.insort(self.items, event.item)
event.succeed()
def _do_get(self, event):
for i in range(len(self.items)):
item = self.items[i]
if event.filter(item):
del self.items[i]
event.succeed(item)
break
return True
【讨论】: