blob: cb016188ee33c5e80a07a4adc093c0e9c968682c (
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
|
#! /usr/bin/env ruby
# -*- coding: UTF-8 -*-
#
module EvenDoors
#
class Twirl
#
@debug_routing = false
@debug_errors = false
@pool = {} # per particle class free list
@sys_fifo = [] # system particles fifo list
@app_fifo = [] # application particles fifo list
#
@run = false
#
class << self
#
attr_accessor :run, :debug_routing, :debug_errors
#
def release_p p
# hope there is no circular loop
while p2=p.merged_shift
release_p p2
end
( @pool[p.class] ||= [] ) << p
end
#
def require_p p_kls
l = @pool[p_kls]
return p_kls.new if l.nil?
p = l.pop
return p_kls.new if p.nil?
p.reset!
p
end
#
def send_p p
@app_fifo << p
end
#
def send_sys_p p
@sys_fifo << p
end
#
def twirl!
while @run and (@sys_fifo.length>0 or @app_fifo.length>0)
while @run and @sys_fifo.length>0
p = @sys_fifo.shift
p.dst.process_sys_p p
end
while @run and @app_fifo.length>0
p = @app_fifo.shift
p.dst.process_p p
break
end
end
end
#
def clear!
@sys_fifo.clear
@app_fifo.clear
end
#
end
#
end
#
end
#
# EOF
|
