working reliably 2

src/decentralizepy/communication/TCPRandomWalk.py

@@ -305,9 +305,11 @@ class TCPRandomWalk(TCPRandomWalkBase):
 
         """
         print("disconnect_neighbors")
+        self.flag_running.value = 0
+        time.sleep(4)
         self.send_queue.close()  # this crashes
         self.recv_queue.close()
-        self.flag_running.value = 0
+
         #del self.lock
         self.send_queue.join_thread()
         self.recv_queue.join_thread()