Sha256: c5fd1a6180e31852ded12527d00ec2b732ce1502b80c20bfb93e30bf309fb3dd
Contents?: true
Size: 1.71 KB
Versions: 22
Compression:
Stored size: 1.71 KB
Contents
# encoding: ascii-8bit
# Copyright 2022 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 Affero General Public License
# as published by the Free Software Foundation; version 3 with
# attribution addendums as found in the LICENSE.txt
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU Affero General Public License for more details.
# Modified by OpenC3, Inc.
# All changes Copyright 2022, OpenC3, Inc.
# All Rights Reserved
#
# This file may also be used under the terms of a commercial license
# if purchased from OpenC3, Inc.
module OpenC3
# 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)
@pipe_reader.close unless @pipe_reader.closed?
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('.')
@pipe_writer.close
end
end
end
end
Version data entries
22 entries across 22 versions & 1 rubygems