python时间滑动窗口变化

这样行吗？我就是这样理解你的问题的。它所做的是创建一个跟踪事物的类。您可以通过tw.insert()添加，也可以通过tw.sum_window(秒)求和。

当你初始化TimeWindow时，你可以给它一个最大大小的参数，默认值是10秒。当您添加元素或计算和时，它会进行清理，以便在每次插入或求和操作之前，第一个元素时间e[0]和最后一个元素时间e[n][0]相差不到10秒。较旧的条目将被删除。一个"轮询器"线程可以跟踪您的请求。

我添加了两个队列，因为我不知道您打算如何处理结果。现在，如果您想在将来从现在开始到5秒请求数据，您可以创建一个请求并将其放入队列。请求具有一个随机id，以便您可以将其与结果相匹配。您的主线程需要监视结果队列，五秒钟后，发送到队列的每个请求都会返回相同的id和总和。

如果这不是你想做的，那么我就是不明白你在这里想要实现什么。即使这已经相当复杂了，而且可能有一种更简单的方法来实现你想要做的事情

import random
import time
import threading
import datetime
import Queue
import uuid
from collections import deque
q_lock = threading.RLock()

class TimeWindow(object):
def __init__(self, max_size=10):
self.max_size = max_size
self.q = deque()
def expire(self):
time_now = datetime.datetime.now()
while True:
try:
oldest_element = self.q.popleft()
oe_time = oldest_element[0]
if oe_time + datetime.timedelta(seconds=self.max_size) > time_now:
self.q.appendleft(oldest_element)
break
except IndexError:
break
def insert(self,elm):
self.expire()
self.q.append(elm)
def sum_window(self, start, end):
self.expire()
try:
_ = self.q[0]
except IndexError:
return 0
result=0
for f in self.q:
if start < f[0] < end:
result += f[1]
else:
pass
return result

tw = TimeWindow()

def t1():
while True:
time.sleep(random.randint(0, 3))
element = [datetime.datetime.now(), random.randint(0,1000)]
with q_lock:
tw.insert(element)

def poller(in_q, out_q):
pending = []
while True:
try:
new_request = in_q.get(0.1)
new_request["end"] = new_request["start"] + datetime.timedelta(seconds=new_request["frame"])
pending.append(new_request)
except Queue.Empty:
pass
new_pending = []
for a in pending:
if a["end"] < datetime.datetime.now():
with q_lock:
r_sum = tw.sum_window(a["start"], a["end"])
r_structure = {"id": a["id"], "result": r_sum}
out_q.put(r_structure)
else:
new_pending.append(a)
pending = new_pending

a = threading.Thread(target=t1)
a.daemon = True
a.start()
in_queue = Queue.Queue()
result_queue = Queue.Queue()
po = threading.Thread(target=poller, args=(in_queue, result_queue,))
po.daemon = True
po.start()
while True:
time.sleep(1)
newr = {"id": uuid.uuid4(), "frame": 5, "start": datetime.datetime.now()}
in_queue.put(newr)
try:
ready = result_queue.get(0)
print ready
except Queue.Empty:
pass