Ticket #11069: boost.patch

boost/asio/detail/impl/task_io_service.ipp

@@ -77 +77 @@
     {
       lock_->lock();
       task_io_service_->op_queue_.push(this_thread_->private_op_queue);
+      lock_->unlock();
     }
 #endif // defined(BOOST_ASIO_HAS_THREADS)
+
+    // If the last handler put a new work into the empty queue
+    // we should wake up a thread for it
+    if(check_new_handlers_)
+    {
+      lock_->lock();
+      if(!task_io_service_->op_queue_.empty())
+        task_io_service_->wake_one_thread_and_unlock(*lock_);
+      else
+        lock_->unlock();
+    }
   }
 
   task_io_service* task_io_service_;
   mutex::scoped_lock* lock_;
   thread_info* this_thread_;
+  bool check_new_handlers_;
 };
 
 task_io_service::task_io_service(
@@ -377 +390 @@
           lock.unlock();
 
         // Ensure the count of outstanding work is decremented on block exit.
-        work_cleanup on_exit = { this, &lock, &this_thread };
+        work_cleanup on_exit = { this, &lock, &this_thread, !more_handlers && !one_thread_ };
         (void)on_exit;
 
         // Complete the operation. May throw an exception. Deletes the object.

boost/asio/detail/posix_event.hpp

@@ -58 +58 @@
   {
     BOOST_ASIO_ASSERT(lock.locked());
     signalled_ = true;
-    lock.unlock();
     ::pthread_cond_signal(&cond_); // Ignore EINVAL.
+    lock.unlock();
   }
 
   // Reset the event.