DBG: make x64dbg run under Wine again

Author: mrexodia

.gitmodules

@@ -11,6 +11,9 @@
 	path = deps
 	url = https://github.com/x64dbg/deps
 	shallow = true
+[submodule "src/dbg/concurrentqueue"]
+	path = src/dbg/concurrentqueue
+	url = https://github.com/cameron314/concurrentqueue.git
 [submodule "src/zydis_wrapper/zydis"]
 	path = src/zydis_wrapper/zydis
 	url = https://github.com/zyantific/zydis.git

src/dbg/concurrentqueue

@@ -42,7 +42,7 @@ bool MsgSend(MESSAGE_STACK* Stack, int Msg, duint Param1, duint Param2)
     newMessage.param2 = Param2;
 
     // Asynchronous send
-    asend(Stack->msgs, newMessage);
+    Stack->msgs.enqueue(newMessage);
     return true;
 }
 
@@ -53,7 +53,7 @@ bool MsgGet(MESSAGE_STACK* Stack, MESSAGE* Msg)
         return false;
 
     // Don't increment the wait count because this does not wait
-    return try_receive(Stack->msgs, *Msg);
+    return Stack->msgs.try_dequeue(*Msg);
 }
 
 // Wait for a message on the specified stack
@@ -64,6 +64,6 @@ void MsgWait(MESSAGE_STACK* Stack, MESSAGE* Msg)
 
     // Increment/decrement wait count
     InterlockedIncrement((volatile long*)&Stack->WaitingCalls);
-    *Msg = Stack->msgs.dequeue();
+    Stack->msgs.wait_dequeue(*Msg);
     InterlockedDecrement((volatile long*)&Stack->WaitingCalls);
 }

src/dbg/msgqueue.cpp

@@ -2,7 +2,7 @@
 #define _MSGQUEUE_H
 
 #include "_global.h"
-#include <agents.h>
+#include "concurrentqueue/blockingconcurrentqueue.h"
 
 #define MAX_MESSAGES 256
 
@@ -18,7 +18,7 @@ struct MESSAGE
 class MESSAGE_STACK
 {
 public:
-    Concurrency::unbounded_buffer<MESSAGE> msgs;
+    moodycamel::BlockingConcurrentQueue<MESSAGE> msgs;
 
     int WaitingCalls;   // Number of threads waiting
     bool Destroy;       // Destroy stack as soon as possible

src/dbg/msgqueue.h

@@ -6,7 +6,6 @@
 #include <thread>
 #include <tuple>
 #include <type_traits>
-#include <utility>
 
 const size_t TASK_THREAD_DEFAULT_SLEEP_TIME = 100;
 template <typename F, typename... Args>
@@ -121,7 +120,7 @@ template <typename F, typename... Args> void TaskThread_<F, Args...>::Loop()
         if(this->active)
         {
             apply_from_tuple(this->fn, argLatch);
-            std::this_thread::sleep_for(std::chrono::milliseconds(this->minSleepTimeMs));
+            Sleep(this->minSleepTimeMs);
             ++this->execs;
         }
     }