about summary refs log tree commit homepage
path: root/lib/yahns/queue_epoll.rb
diff options
context:
space:
mode:
authorEric Wong <e@80x24.org>2013-10-28 06:51:04 +0000
committerEric Wong <normalperson@yhbt.net>2013-10-28 06:55:46 +0000
commit4602e200cff9da896339cd3bcf88c519ea96fdc5 (patch)
tree1273a56a3e851c12d21081a2c4c873ad0082f061 /lib/yahns/queue_epoll.rb
parenta667bc3787eaaf5b7df3b70624985d5fb5b8fc61 (diff)
downloadyahns-4602e200cff9da896339cd3bcf88c519ea96fdc5.tar.gz
We use QueueQuitter, nowadays, so we no longer rely on cross-thread
close to destroy a running thread blocked on epoll_wait.
Diffstat (limited to 'lib/yahns/queue_epoll.rb')
-rw-r--r--lib/yahns/queue_epoll.rb2
1 files changed, 0 insertions, 2 deletions
diff --git a/lib/yahns/queue_epoll.rb b/lib/yahns/queue_epoll.rb
index 397df7a..c22a624 100644
--- a/lib/yahns/queue_epoll.rb
+++ b/lib/yahns/queue_epoll.rb
@@ -52,8 +52,6 @@ class Yahns::Queue < SleepyPenguin::Epoll::IO # :nodoc:
           end
         end
       rescue => e
-        # sleep since this check is racy (and uncommon)
-        break if closed? || (sleep(0.01) && closed?)
         Yahns::Log.exception(logger, 'queue loop', e)
       end while true
     end