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