reset queue when restart

Source/CarlaServer/source/carla/server/CarlaCommunication.cpp

@@ -251,6 +251,11 @@ namespace server {
 
   void CarlaCommunication::sendWorld(const uint32_t modes,const uint32_t scenes) {
 
+    //ClearThreads
+    _worldThread.clear();
+    _clientThread.clear();
+    _serverThread.clear();
+
     World world;
     _proto->LoadWorld(world, modes, scenes);
 

Source/CarlaServer/source/carla/thread/AsyncReadWriteJobQueue.h

@@ -71,6 +71,11 @@ namespace thread {
       return _restart;
     }
 
+    void clear(){
+      _readQueue.clear();
+      _writeQueue.clear();
+    }
+
   private:
 
     void workerThread() {

Source/CarlaServer/source/carla/thread/AsyncReaderJobQueue.h

@@ -55,6 +55,10 @@ namespace thread {
       _reconnectJob();
     }
 
+    void clear(){
+      _queue.clear();
+    }
+    
   private:
     void workerThread() {
       while (!_done){

Source/CarlaServer/source/carla/thread/AsyncWriterJobQueue.h

@@ -53,6 +53,10 @@ namespace thread {
       _reconnectJob();
     }
 
+    void clear(){
+      _queue.clear();
+    }
+    
   private:
 
     void workerThread() {

Source/CarlaServer/source/carla/thread/ThreadSafeQueue.h

@@ -63,6 +63,10 @@ namespace thread {
 	    }*/
     }
     
+    void clear(){
+      _value = nullptr;
+    }
+
     bool empty() const {
       std::lock_guard<std::mutex> lock(_mutex);
       //return _queue.empty();