Package org.jruby.ext.timeout

Class Timeout

java.lang.Object

org.jruby.ext.timeout.Timeout

public class Timeout
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	Timeout.TimeoutTask

Field Summary

Fields

Modifier and Type	Field	Description
static final String	EXECUTOR_VARIABLE
private static final ByteList	TIMEOUT_MESSAGE

Constructor Summary

Constructors

Constructor	Description
Timeout()

Method Summary

Modifier and Type	Method	Description
private static RubyString	defaultTimeoutMessage(ThreadContext context)
static void	define(RubyModule timeout)
private static RubyClass	getTimeoutError(RubyModule timeout)
private static void	killTimeoutThread(ThreadContext context, ScheduledFuture timeoutFuture, AtomicBoolean latch)
static void	load(Ruby runtime)
private static boolean	nilOrZeroSeconds(ThreadContext context, IRubyObject seconds)
private static IRubyObject	raiseTimeoutErrorIfMatches(ThreadContext context, RubyModule timeout, RaiseException ex, Object id)
static IRubyObject	timeout(ThreadContext context, IRubyObject recv, IRubyObject seconds, Block block)
static IRubyObject	timeout(ThreadContext context, IRubyObject recv, IRubyObject seconds, IRubyObject exceptionType, Block block)
static IRubyObject	timeout(ThreadContext context, IRubyObject recv, IRubyObject seconds, IRubyObject exceptionType, IRubyObject message, Block block)
private static IRubyObject	yieldWithTimeout(ScheduledThreadPoolExecutor executor, ThreadContext context, IRubyObject seconds, Block block, Runnable runnable, AtomicBoolean latch)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

EXECUTOR_VARIABLE

public static final String EXECUTOR_VARIABLE

See Also:

• Constant Field Values

TIMEOUT_MESSAGE

private static final ByteList TIMEOUT_MESSAGE

Constructor Details

Timeout

public Timeout()

Method Details

load

public static void load(Ruby runtime)

define

public static void define(RubyModule timeout)

timeout

public static IRubyObject timeout(ThreadContext context,
 IRubyObject recv,
 IRubyObject seconds,
 Block block)

defaultTimeoutMessage

private static RubyString defaultTimeoutMessage(ThreadContext context)

timeout

public static IRubyObject timeout(ThreadContext context,
 IRubyObject recv,
 IRubyObject seconds,
 IRubyObject exceptionType,
 Block block)

timeout

public static IRubyObject timeout(ThreadContext context,
 IRubyObject recv,
 IRubyObject seconds,
 IRubyObject exceptionType,
 IRubyObject message,
 Block block)

nilOrZeroSeconds

private static boolean nilOrZeroSeconds(ThreadContext context,
 IRubyObject seconds)

yieldWithTimeout

private static IRubyObject yieldWithTimeout(ScheduledThreadPoolExecutor executor,
 ThreadContext context,
 IRubyObject seconds,
 Block block,
 Runnable runnable,
 AtomicBoolean latch)
                                     throws RaiseException

Throws:

RaiseException

killTimeoutThread

private static void killTimeoutThread(ThreadContext context,
 ScheduledFuture timeoutFuture,
 AtomicBoolean latch)

raiseTimeoutErrorIfMatches

private static IRubyObject raiseTimeoutErrorIfMatches(ThreadContext context,
 RubyModule timeout,
 RaiseException ex,
 Object id)

getTimeoutError

private static RubyClass getTimeoutError(RubyModule timeout)