Sha256: 7f39c44191ef6cfc16639f4e86c39b80425ca6b710eeb048ac914e3893ce1617
Contents?: true
Size: 1.21 KB
Versions: 64
Compression:
Stored size: 1.21 KB
Contents
# encoding: ascii-8bit
# Copyright 2014 Ball Aerospace & Technologies Corp.
# All Rights Reserved.
#
# This program is free software; you can modify and/or redistribute it
# under the terms of the GNU General Public License
# as published by the Free Software Foundation; version 3 with
# attribution addendums as found in the LICENSE.txt
module Cosmos
# Allows for a breakable sleep implementation using the self-pipe trick
# See http://www.sitepoint.com/the-self-pipe-trick-explained/
class Sleeper
def initialize
@pipe_reader, @pipe_writer = IO.pipe
@readers = [@pipe_reader]
@canceled = false
end
# Breakable version of sleep
# @param seconds Number of seconds to sleep
# @return true if the sleep was broken by someone calling cancel
# otherwise returns false
def sleep(seconds)
read_ready, _ = IO.select(@readers, nil, nil, seconds)
if read_ready && read_ready.include?(@pipe_reader)
return true
else
return false
end
end
# Break sleeping - Once canceled a sleeper cannot be used again
def cancel
if !@canceled
@canceled = true
@pipe_writer.write('.')
end
end
end
end # module Cosmos
Version data entries
64 entries across 64 versions & 1 rubygems