class Autobuild::RakeTaskParallelism::JobServer
Attributes
rio[R]
wio[R]
Public Class Methods
new(level)
click to toggle source
# File lib/autobuild/parallel.rb, line 12 def initialize(level) @rio, @wio = IO.pipe # Clearing cloexec rio.fcntl(Fcntl::F_SETFD, 0) wio.fcntl(Fcntl::F_SETFD, 0) put(level) end
Public Instance Methods
get(token_count = 1)
click to toggle source
# File lib/autobuild/parallel.rb, line 20 def get(token_count = 1) @rio.read(token_count) end
put(token_count = 1)
click to toggle source
# File lib/autobuild/parallel.rb, line 24 def put(token_count = 1) @wio.write(" " * token_count) end