#40 Fix crash on Linux.

src/workers/DoubleWorker.cpp

@@ -62,7 +62,7 @@ DoubleWorker::~DoubleWorker()
 
 void DoubleWorker::start()
 {
-    while (true) {
+    while (Workers::sequence() > 0) {
         if (Workers::isPaused()) {
             do {
                 std::this_thread::sleep_for(std::chrono::milliseconds(200));

src/workers/Handle.cpp

@@ -34,6 +34,12 @@ Handle::Handle(int threadId, int threads, int64_t affinity) :
 }
 
 
+void Handle::join()
+{
+    uv_thread_join(&m_thread);
+}
+
+
 void Handle::start(void (*callback) (void *))
 {
     uv_thread_create(&m_thread, callback, this);

src/workers/Handle.h

@@ -36,6 +36,7 @@ class Handle
 {
 public:
     Handle(int threadId, int threads, int64_t affinity);
+    void join();
     void start(void (*callback) (void *));
 
     inline int threadId() const            { return m_threadId; }

src/workers/SingleWorker.cpp

@@ -38,7 +38,7 @@ SingleWorker::SingleWorker(Handle *handle)
 
 void SingleWorker::start()
 {
-    while (true) {
+    while (Workers::sequence() > 0) {
         if (Workers::isPaused()) {
             do {
                 std::this_thread::sleep_for(std::chrono::milliseconds(200));

src/workers/Workers.cpp

@@ -100,7 +100,7 @@ void Workers::start(int64_t affinity)
     uv_mutex_init(&m_mutex);
     uv_rwlock_init(&m_rwlock);
 
-    m_sequence = 0;
+    m_sequence = 1;
     m_paused   = 1;
 
     uv_async_init(uv_default_loop(), &m_async, Workers::onResult);
@@ -121,6 +121,11 @@ void Workers::stop()
     m_hashrate->stop();
 
     uv_close(reinterpret_cast<uv_handle_t*>(&m_async), nullptr);
+    m_sequence = 0;
+
+    for (size_t i = 0; i < m_workers.size(); ++i) {
+        m_workers[i]->join();
+    }
 }