アイテムがいっぱいになると自動的にアイテムを破棄する破棄 FIFO キューが必要です。スレッドセーフである必要はありません。もっと重要なら効率。
つまり、半ランダムな時間に最後のn秒間 (オブジェクト) を取得しながら、デバイスから信号をサンプリングする必要があります。
私は (あまりスレッドセーフではない) バッファを自分で実装しましたが、ここで車輪を再発明していると感じています。さらに、毎秒 100 個のオブジェクトについて話しています。ほとんどは破棄されますが、たとえば、一度に 3000 (= 30 秒のデータ) を取得する必要があります (たとえば、10 分ごと)。
そのようなクラスは既に Python 標準ライブラリまたは他の場所にありますか? 私はいくつかのゴーグルフーを使用しましたが、有用なものを見つけることができませんでした.
DiscardingBuffer
from Queue import Queue, Full, Empty
import logging
class DiscardingBuffer():
def __init__(self, capacity=0):
self._queue = Queue(maxsize=capacity)
def put(self, item):
while True:
try:
self._queue.put(item, block=False)
logging.debug('Put item: {0}'.format(item))
break
except Full:
discarded_item = self._queue.get(block=False)
logging.debug('Buffer is full. Discarding: {0}'.format(discarded_item))
def flush(self):
items = []
while True:
try:
items.append(self._queue.get(block=False))
except Empty:
logging.debug('Buffer is now empty.')
break
return items
def main():
buf = DiscardingBuffer(5)
for i in xrange(10):
buf.put(i)
logging.debug('Remaining items: {0}'.format(buf.flush()))
logging.debug('Verify it is empty: {0}'.format(buf.flush()))
if __name__ == '__main__':
logging.basicConfig(level=logging.DEBUG,
format='[%(levelname)1.1s %(asctime)s %(name)s (%(process)d):%(lineno)d] %(message)s',
datefmt='%Y-%m-%d %H:%M:%S')
main()
出力
[D 2013-08-22 10:13:58 root (4164):13] Put item: 0
[D 2013-08-22 10:13:58 root (4164):13] Put item: 1
[D 2013-08-22 10:13:58 root (4164):13] Put item: 2
[D 2013-08-22 10:13:58 root (4164):13] Put item: 3
[D 2013-08-22 10:13:58 root (4164):13] Put item: 4
[D 2013-08-22 10:13:58 root (4164):17] Buffer is full. Discarding: 0
[D 2013-08-22 10:13:58 root (4164):13] Put item: 5
[D 2013-08-22 10:13:58 root (4164):17] Buffer is full. Discarding: 1
[D 2013-08-22 10:13:58 root (4164):13] Put item: 6
[D 2013-08-22 10:13:58 root (4164):17] Buffer is full. Discarding: 2
[D 2013-08-22 10:13:58 root (4164):13] Put item: 7
[D 2013-08-22 10:13:58 root (4164):17] Buffer is full. Discarding: 3
[D 2013-08-22 10:13:58 root (4164):13] Put item: 8
[D 2013-08-22 10:13:58 root (4164):17] Buffer is full. Discarding: 4
[D 2013-08-22 10:13:58 root (4164):13] Put item: 9
[D 2013-08-22 10:13:58 root (4164):26] Buffer is now empty.
[D 2013-08-22 10:13:58 root (4164):38] Remaining items: [5, 6, 7, 8, 9]
[D 2013-08-22 10:13:58 root (4164):26] Buffer is now empty.
[D 2013-08-22 10:13:58 root (4164):39] Verify it is empty: []