update example
This commit is contained in:
@@ -113,6 +113,7 @@ def main():
|
|||||||
# =========================================================================
|
# =========================================================================
|
||||||
# 1. 配置多个传感器
|
# 1. 配置多个传感器
|
||||||
# =========================================================================
|
# =========================================================================
|
||||||
|
num_sensors = 2
|
||||||
sensor_configs = [
|
sensor_configs = [
|
||||||
{
|
{
|
||||||
'vid_src': './s1.mp4',
|
'vid_src': './s1.mp4',
|
||||||
@@ -127,7 +128,7 @@ def main():
|
|||||||
# =========================================================================
|
# =========================================================================
|
||||||
# 2. 创建进程间通信对象
|
# 2. 创建进程间通信对象
|
||||||
# =========================================================================
|
# =========================================================================
|
||||||
result_queues = [Queue(maxsize=2) for _ in sensor_configs] # 每个传感器一个队列
|
result_queues = [Queue(maxsize=num_sensors) for _ in sensor_configs] # 每个传感器一个队列
|
||||||
stop_events = [mp.Event() for _ in sensor_configs] # 停止事件
|
stop_events = [mp.Event() for _ in sensor_configs] # 停止事件
|
||||||
|
|
||||||
# =========================================================================
|
# =========================================================================
|
||||||
|
|||||||
Reference in New Issue
Block a user