Python解释器中的后台线程暂停时间.sleep()
发布时间:2020-12-20 13:36:51 所属栏目:Python 来源:网络整理
导读:我们已经构建了一个自定义 python解释器,并且正在尝试创建一个函数来启动后台线程,该后台线程定期调用函数来获取传感器读数,然后将该读取存储在循环缓冲区内(使用最大长度的双端队列实现) ). 下面显示了我们实施的简化版本.我们面临的问题是,当我们从解释器
|
我们已经构建了一个自定义
python解释器,并且正在尝试创建一个函数来启动后台线程,该后台线程定期调用函数来获取传感器读数,然后将该读取存储在循环缓冲区内(使用最大长度的双端队列实现) ).
下面显示了我们实施的简化版本.我们面临的问题是,当我们从解释器调用monitor_sensor()来开始后台线程时,后台线程中的代码似乎只执行一次(我们通过查看sensor_values的内容来确定).此外,当我们尝试退出解释器(使用exit())时,解释器挂起并且永不退出. import code
import collections
import threading
def get_sensor_reading():
return 5.0
sensor_values = {}
def monitor_sensor():
sensor_values['sensor_1'] = collections.deque(maxlen=1000)
background_thread = threading.Thread(target=run_monitor_sensor,args=[sensor_values,get_sensor_reading])
background_thread.start()
def run_monitor_sensor(sensor_values,read_sensor_cmd):
while True:
reading = read_sensor_cmd()
sensor_values['sensor_1'].append(reading)
import time
time.sleep(1)
imported_objects = {'monitor_sensor': monitor_sensor,'sensor_values': sensor_values}
code.interact(local=imported_objects)
下面显示了解释器会话的转储,我们尝试运行后台线程并查看存储的数据 – 请注意,我们等待的时间远远超过读取sensor_values中值的1秒睡眠时间. 218> python manage.py example
Python 2.7.3 (default,Aug 1 2012,05:16:07)
[GCC 4.6.3] on linux2
Type "help","copyright","credits" or "license" for more information.
(InteractiveConsole)
>>> monitor_sensor()
>>> sensor_values
{'sensor_1': deque([5.0],maxlen=1000)}
>>> sensor_values
{'sensor_1': deque([5.0],maxlen=1000)}
问题似乎是调用time.sleep(1) – 如果我们删除它,那么缓冲区将很快填满值.任何人都可以告诉我们为什么会出现这个问题,以及我们如何解决它? 更新 我们通过将导入时间从循环内部移动到模块级来解决了这个问题.到目前为止,没有任何线索可以解决这个问题,但如果有人能够回答这个问题,那么就会接受这个答案. 解决方法
你在没有锁的情况下在两个线程之间共享一个可变值.
这实际上并不能保证是Python中的一个问题,它可能不是你的问题…但它肯定是错的,它可能会导致这样的问题. 要修复它,请执行以下操作: sensor_values = {}
sensor_lock = threading.Lock()
def monitor_sensor():
sensor_values['sensor_1'] = collections.deque(maxlen=1000)
background_thread = threading.Thread(target=run_monitor_sensor,get_sensor_reading,sensor_lock])
background_thread.start()
def run_monitor_sensor(sensor_values,read_sensor_cmd,sensor_lock):
while True:
reading = read_sensor_cmd()
with sensor_lock:
sensor_values['sensor_1'].append(reading)
import time
time.sleep(1)
def get_sensor_values():
with sensor_lock:
return sensor_values
(编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |
