blob: 2715c5e9feabeb4f721b8363c6e00054b8391faa (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
=begin
external service manager
Copyright (c) 2000 Masatoshi SEKI
=end
require 'drb/drb'
require 'thread'
module DRb
class ExtServManager
include DRbUndumped
@@command = {}
def self.command
@@command
end
def self.command=(cmd)
@@command = cmd
end
def initialize
@servers = {}
@waiting = []
@queue = Queue.new
@thread = invoke_thread
@uri = nil
end
attr_accessor :uri
def service(name)
while true
server = nil
Thread.exclusive do
server = @servers[name] if @servers[name]
end
return server if server && server.alive?
invoke_service(name)
end
end
def regist(name, ro)
ary = nil
Thread.exclusive do
@servers[name] = ro
ary = @waiting
@waiting = []
end
ary.each do |th|
begin
th.run
rescue ThreadError
end
end
self
end
def unregist(name)
Thread.exclusive do
@servers.delete(name)
end
end
private
def invoke_thread
Thread.new do
while true
name = @queue.pop
invoke_service_command(name, @@command[name])
end
end
end
def invoke_service(name)
Thread.critical = true
@waiting.push Thread.current
@queue.push name
Thread.stop
end
def invoke_service_command(name, command)
raise "invalid command. name: #{name}" unless command
Thread.exclusive do
return if @servers.include?(name)
@servers[name] = false
end
uri = @uri || DRb.uri
Process.detach(Process.spawn("#{command} #{uri} #{name}"))
true
end
end
end
|
