@@ -34,7 +34,7 @@ def counting(count, ivar)
34
34
ivar . set count
35
35
end
36
36
end
37
- end
37
+ end if defined? Celluloid
38
38
39
39
threads = [ ]
40
40
@@ -72,26 +72,28 @@ def counting(count, ivar)
72
72
adders . each { |a | a << :terminate! }
73
73
end
74
74
75
- b . report ( format ( '%5d %4d %s' , ADD_TO *counts_size , adders_size , 'celluloid' ) ) do
76
- counts = [ ]
77
- counts_size . times { counts << [ 0 , Concurrent ::IVar . new ] }
75
+ if defined? Celluloid
76
+ b . report ( format ( '%5d %4d %s' , ADD_TO *counts_size , adders_size , 'celluloid' ) ) do
77
+ counts = [ ]
78
+ counts_size . times { counts << [ 0 , Concurrent ::IVar . new ] }
78
79
79
- adders = [ ]
80
- adders_size . times do |i |
81
- adders << Counter . new ( adders , i )
82
- end
80
+ adders = [ ]
81
+ adders_size . times do |i |
82
+ adders << Counter . new ( adders , i )
83
+ end
83
84
84
- counts . each_with_index do |count , i |
85
- adders [ i % adders_size ] . counting *count
86
- end
85
+ counts . each_with_index do |count , i |
86
+ adders [ i % adders_size ] . counting *count
87
+ end
87
88
88
- counts . each do |count , ivar |
89
- raise unless ivar . value >= ADD_TO
90
- end
89
+ counts . each do |count , ivar |
90
+ raise unless ivar . value >= ADD_TO
91
+ end
91
92
92
- threads << Thread . list . size
93
+ threads << Thread . list . size
93
94
94
- adders . each ( &:terminate )
95
+ adders . each ( &:terminate )
96
+ end
95
97
end
96
98
end
97
99
end
0 commit comments