We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b03c49f commit 4043e35Copy full SHA for 4043e35
lib/concurrent/channel/buffer/base.rb
@@ -1,5 +1,4 @@
1
require 'concurrent/synchronization/lockable_object'
2
-require 'concurrent/utility/at_exit'
3
4
module Concurrent
5
class Channel
@@ -33,7 +32,6 @@ def initialize(*args)
33
32
@capacity = 0
34
@buffer = nil
35
ns_initialize(*args)
36
- AtExit.add(self) { terminate_at_exit }
37
end
38
39
@@ -234,11 +232,6 @@ def ns_full?
234
232
def ns_closed?
235
233
@closed
236
237
-
238
- # @!visibility private
239
- def terminate_at_exit
240
- synchronize { self.closed = true }
241
- end
242
243
244
0 commit comments