1999-08-13 01:45:20 -04:00
|
|
|
#
|
|
|
|
# timeout.rb -- execution timeout
|
|
|
|
#
|
2000-05-01 05:42:38 -04:00
|
|
|
# Copyright (C) 2000 Network Applied Communication Laboratory, Inc.
|
2000-05-09 00:53:16 -04:00
|
|
|
# Copyright (C) 2000 Information-technology Promotion Agency, Japan
|
2000-05-01 05:42:38 -04:00
|
|
|
#
|
1999-08-13 01:45:20 -04:00
|
|
|
#= SYNOPSIS
|
|
|
|
#
|
|
|
|
# require 'timeout'
|
|
|
|
# status = timeout(5) {
|
|
|
|
# # something may take time
|
|
|
|
# }
|
|
|
|
#
|
|
|
|
#= DESCRIPTION
|
|
|
|
#
|
|
|
|
# timeout executes the block. If the block execution terminates successfully
|
|
|
|
# before timeout, it returns true. If not, it terminates the execution and
|
|
|
|
# raise TimeoutError exception.
|
|
|
|
#
|
|
|
|
#== Parameters
|
|
|
|
#
|
|
|
|
# : timout
|
|
|
|
#
|
|
|
|
# The time in seconds to wait for block teminatation.
|
|
|
|
#
|
|
|
|
#=end
|
|
|
|
|
|
|
|
class TimeoutError<StandardError
|
|
|
|
end
|
|
|
|
|
|
|
|
def timeout(sec)
|
2000-05-30 00:24:17 -04:00
|
|
|
return yield if sec == nil
|
1999-08-13 01:45:20 -04:00
|
|
|
begin
|
|
|
|
x = Thread.current
|
|
|
|
y = Thread.start {
|
|
|
|
sleep sec
|
2000-01-04 23:41:21 -05:00
|
|
|
x.raise TimeoutError, "execution expired" if x.alive?
|
1999-08-13 01:45:20 -04:00
|
|
|
}
|
|
|
|
yield sec
|
|
|
|
return true
|
|
|
|
ensure
|
2000-01-04 23:41:21 -05:00
|
|
|
Thread.kill y if y.alive?
|
1999-08-13 01:45:20 -04:00
|
|
|
end
|
|
|
|
end
|