lib/evendoors/twirl.rb


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

#! /usr/bin/env ruby
# -*- coding: UTF-8 -*-

#
module EvenDoors
    #
    class Twirl
        #
        @debug = 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 :debug, :run
            #
            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