Add queues to workers randomly

kdtree/runtime/runtime.pxd

@@ -106,10 +106,12 @@ cdef cypclass Scheduler:
     atomic[int] num_pending_queues
     sem_t done
     volatile bint is_done
+    int num_workers
 
     lock Scheduler __new__(alloc, int num_workers=0):
         self = <lock Scheduler> consume alloc()
         if num_workers == 0: num_workers = sysconf(_SC_NPROCESSORS_ONLN)
+        self.num_workers = num_workers
         sem_init(&self.num_free_queues, 0, 0)
         sem_init(&self.done, 0, 0)
         self.num_pending_queues.store(0)
@@ -138,10 +140,10 @@ cdef cypclass Scheduler:
 
     void post_queue(self, lock SequentialMailBox queue):
         # Add a queue to the first worker.
-        main_worker = self.workers[0]
-        with wlocked main_worker:
+        receiver = self.workers[rand() % self.num_workers]
+        with wlocked receiver:
           queue.has_worker = True
-          main_worker.queues.push_back(queue)
+          receiver.queues.push_back(queue)
         # Increment the number of non-completed queues.
         self.num_pending_queues.fetch_add(1)
         # Signal that a queue is available.