Contents

require 'thread'
require 'fcntl'

module Hydra
  class ThreadsafeIO < IO
    def initialize(existing_io)
      fd = existing_io.fcntl(Fcntl::F_DUPFD)
      super(fd)
      @mutex = Mutex.new
    end

    def write(*args)
      @mutex.synchronize do
        super(*args)
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 3 rubygems

Version	Path
arturop-hydra-0.24.0	lib/hydra/threadsafe_io.rb
nulogy-hydra-0.23.2.1	lib/hydra/threadsafe_io.rb
justinf-hydra-0.23.8	lib/hydra/threadsafe_io.rb
justinf-hydra-0.23.7	lib/hydra/threadsafe_io.rb