Class: Thread

Inherits:

Object

show all

Defined in:: lib/thread/promise.rb,
lib/thread/process.rb,
lib/thread/channel.rb,
lib/thread/future.rb,
lib/thread/every.rb,
lib/thread/delay.rb,
lib/thread/pool.rb,
lib/thread/pipe.rb

Defined Under Namespace

Classes: Channel, Delay, Every, Future, Pipe, Pool, Process

Helper to create a channel.



106
107
108

# File 'lib/thread/channel.rb', line 106

def self.channel(*args, &block)
  Thread::Channel.new(*args, &block)
end

Helper to create Thread::Delay



84
85
86

# File 'lib/thread/delay.rb', line 84

def self.delay (&block)
  Thread::Delay.new(&block)
end

Helper to create an every



187
188
189

# File 'lib/thread/every.rb', line 187

def self.every(every, &block)
  Thread::Every.new(every, &block)
end

Helper to create a future



151
152
153

# File 'lib/thread/future.rb', line 151

def self.future(pool = nil, &block)
  Thread::Future.new(pool, &block)
end

Helper to create a pool.



475
476
477

# File 'lib/thread/pool.rb', line 475

def self.pool(*args, &block)
  Thread::Pool.new(*args, &block)
end

Helper to create a process.



68
69
70

# File 'lib/thread/process.rb', line 68

def self.process(&block)
  Thread::Process.new(&block)
end

Helper method to create a promise.



73
74
75

# File 'lib/thread/promise.rb', line 73

def self.promise
  Thread::Promise.new
end

Helper to create a pipe.



116
117
118

# File 'lib/thread/pipe.rb', line 116

def self.|(func)
  Pipe.new | func
end