class Autobuild::RakeTaskParallelism::JobServer
Attributes
Public Class Methods
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
Source
# File lib/autobuild/parallel.rb, line 20 def get(token_count = 1) @rio.read(token_count) end
Source
# File lib/autobuild/parallel.rb, line 24 def put(token_count = 1) @wio.write(" " * token_count) end