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
Should change thread-shared variables like ints and floats to multiprocessing Values #8
Closed
DerekGloudemans closed 4 years ago
This is a better and safer way to do this,
Need to change average_wait_time and num_worker_tasks to this form.