aggregate/pmq: we need a Mutex to protect fcntl() locks
commitfa64d77ac096612d6bc731407066df8aa1ff79a7
authorEric Wong <normalperson@yhbt.net>
Thu, 10 Mar 2011 00:54:46 +0000 (9 16:54 -0800)
committerEric Wong <normalperson@yhbt.net>
Thu, 10 Mar 2011 00:54:46 +0000 (9 16:54 -0800)
tree2a6254b95e37a82d93eacfd86fe52a5921c6f714
parentb57881c86de4e7406ca537b5285f27d7130b0073
aggregate/pmq: we need a Mutex to protect fcntl() locks

fcntl() locks are per-process, so we also need something
to protect individual threads within a process from stepping
over each other.
lib/raindrops/aggregate/pmq.rb