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
94
95
96
97
98
99
100
101
102
103
104
105
106
|
# -*- coding: utf-8 -*-
=begin rdoc
遅延評価オブジェクト。
インスタンスのメソッドが呼ばれると、コンストラクタに渡されたブロックが実行され、その戻り値のメソッドに
処理が移譲される。
二回目以降は、初回のブロックの実行結果に対してメソッドが移譲される。
=end
class IrregularEval
Object.methods.each{ |method|
define_method(method){ |*args, &proc|
method_missing(method, *args, &proc) } }
def irregulareval?
true end
def method_missing(method, *args, &block)
irregular_eval_object.__send__(method, *args, &block) end end
class Lazy < IrregularEval
def initialize(&block)
raise 'no block given.' unless block
@proc = block
@obj = nil end
def irregular_eval_object
if @proc
@obj = @proc.call
@proc = nil end
@obj end end
# 毎回評価
# Lazyの、呼び出しごとにブロックを評価するバージョン。
class EveryTime < IrregularEval
def initialize(&block)
raise 'no block given.' unless block
@proc = block end
def irregular_eval_object
@proc.call end end
# 平行評価
# このインスタンスはすぐに別スレッドでブロックの評価が始まり、そのブロックの戻り値として振舞う。
# ただし、ブロックの処理が終わる前にこのオブジェクトを参照した場合、参照元のスレッドは値が返るまで
# ブロッキングされる
class Parallel < IrregularEval
def initialize(&block)
raise 'no block given.' unless block
@proc = Thread.new(&block)
@obj = nil end
def irregular_eval_object
if @proc
@obj = @proc.value
@proc = nil end
@obj end end
# メソッド呼び出しを遅延する。
# 呼び出すメソッドのオブジェクト部分をこのオブジェクトに置き換えると、そのメソッド呼び出しが
# 記録され、MethodCallDelayer#call が呼ばれたときに、callの引数をオブジェクトとして評価が開始される。
# f = function.map{ |x| x + 1 }.join(', ')
# f.call([1, 2, 3]) # => "2, 3, 4"
class MethodCallDelayer < IrregularEval
def initialize
@callstack = lambda{ |x| x } end
def method_missing(*args, &block)
callstack = @callstack
@callstack = lambda{ |x|
callstack.call(x).__send__(*args, &block) }
self end
# _obj_ をselfとして評価を開始する。
def call(obj)
to_proc.call(obj) end
# Procオブジェクトにして返す。
# ブロック引数としてこのオブジェクトを渡した場合に内部で呼ばれる。
def to_proc
@callstack end end
# 遅延評価オブジェクトを作成する。ブロックを取って呼ばれた場合は Lazy のインスタンスを、
# 何も取らずに読んだ場合は MethodCallDelayer のインスタンスを返す。
def lazy(&proc)
if proc
Lazy.new(&proc)
else
MethodCallDelayer.new end end
# 毎回評価オブジェクトを作成する
def everytime(&proc)
EveryTime.new(&proc) end
# 平行評価オブジェクトを作成する
def parallel(&proc)
Parallel.new(&proc) end
# 値が真であるならtrueを返す。遅延評価オブジェクトでも正確に判断することができる。
def bool(val)
not(val.nil? or val.is_a?(FalseClass)) end
|
