search

DerekGloudemans / distributed-detection

Performs stream processing (nominally object detection) across multiple worker processes with decentralized load balancing, decentralized database with eventual consistency, and basic fault monitoring.
0 stars 1 forks source link

Heartbeat needs access to length of work_function thread's internal task_list and audit_list length #7

Closed DerekGloudemans closed 4 years ago

DerekGloudemans commented 4 years ago

Using task_queue and audit_queue lengths don't work well because they are repeatedly emptied into internal lists. Need a thread-shared variable that stores this length

DerekGloudemans commented 4 years ago

Resolved via shared variable p_num_tasks