Skip to content

Commit 544094a

Browse files
committed
Better organisaion of methods.
1 parent 7c58b75 commit 544094a

File tree

1 file changed

+12
-12
lines changed

1 file changed

+12
-12
lines changed

lib/async/scheduler.rb

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,16 @@ def initialize(parent = nil, selector: nil)
5757
end
5858
end
5959

60+
def set!
61+
Fiber.set_scheduler(self)
62+
@loop = Fiber.current
63+
end
64+
65+
def clear!
66+
Fiber.set_scheduler(nil)
67+
@loop = nil
68+
end
69+
6070
def interrupt
6171
@interrupt.signal('!')
6272
end
@@ -87,10 +97,6 @@ def transfer
8797
@loop.transfer
8898
end
8999

90-
def kernel_sleep(duration)
91-
self.block(nil, duration)
92-
end
93-
94100
# Invoked when a fiber tries to perform a blocking operation which cannot continue. A corresponding call {unblock} must be performed to allow this fiber to continue.
95101
# @reentrant Not thread safe.
96102
def block(blocker, timeout)
@@ -125,20 +131,14 @@ def unblock(blocker, fiber)
125131
end
126132
end
127133

128-
def set!
129-
Fiber.set_scheduler(self)
130-
@loop = Fiber.current
134+
def kernel_sleep(duration)
135+
self.block(nil, duration)
131136
end
132137

133138
def address_resolve(hostname)
134139
::Resolv.getaddresses(hostname)
135140
end
136141

137-
def clear!
138-
Fiber.set_scheduler(nil)
139-
@loop = nil
140-
end
141-
142142
def io_wait(io, events, timeout = nil)
143143
fiber = Fiber.current
144144

0 commit comments

Comments
 (0)