org.jruby.ext.timeout

Class Timeout

java.lang.Object

org.jruby.ext.timeout.Timeout

All Implemented Interfaces:

Library

public class Timeout
extends java.lang.Object
implements Library

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	Timeout.TimeoutTask
static class	Timeout.TimeoutToplevel

Field Summary

Fields

Modifier and Type	Field and Description
private static java.util.concurrent.ScheduledExecutorService	timeoutExecutor

Constructor Summary

Constructors

Constructor and Description
Timeout()

Method Summary

Modifier and Type	Method and Description
private static RubyClass	getAnonymousException(IRubyObject timeout)
private static RubyClass	getClassFrom(IRubyObject timeout, java.lang.String name)
private static void	killTimeoutThread(ThreadContext context, java.util.concurrent.Future timeoutFuture, java.util.concurrent.atomic.AtomicBoolean latch)
void	load(Ruby runtime, boolean wrap)
private static boolean	nilOrZeroSeconds(ThreadContext context, IRubyObject seconds)
private static IRubyObject	raiseBecauseCritical(ThreadContext context)
private static IRubyObject	raiseTimeoutErrorIfMatches(ThreadContext context, IRubyObject timeout, RaiseException ex, IRubyObject 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)
private static IRubyObject	yieldWithTimeout(ThreadContext context, IRubyObject seconds, Block block, java.lang.Runnable runnable, java.util.concurrent.atomic.AtomicBoolean latch)

Methods inherited from class java.lang.Object

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

Field Detail

timeoutExecutor

private static java.util.concurrent.ScheduledExecutorService timeoutExecutor

Constructor Detail

Timeout

public Timeout()

Method Detail

load

public void load(Ruby runtime,
                 boolean wrap)
          throws java.io.IOException

Specified by:

load in interface Library

Throws:

java.io.IOException

timeout

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

timeout

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

nilOrZeroSeconds

private static boolean nilOrZeroSeconds(ThreadContext context,
                                        IRubyObject seconds)

yieldWithTimeout

private static IRubyObject yieldWithTimeout(ThreadContext context,
                                            IRubyObject seconds,
                                            Block block,
                                            java.lang.Runnable runnable,
                                            java.util.concurrent.atomic.AtomicBoolean latch)
                                     throws RaiseException

Throws:

RaiseException

killTimeoutThread

private static void killTimeoutThread(ThreadContext context,
                                      java.util.concurrent.Future timeoutFuture,
                                      java.util.concurrent.atomic.AtomicBoolean latch)

raiseBecauseCritical

private static IRubyObject raiseBecauseCritical(ThreadContext context)

raiseTimeoutErrorIfMatches

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

getAnonymousException

private static RubyClass getAnonymousException(IRubyObject timeout)

getClassFrom

private static RubyClass getClassFrom(IRubyObject timeout,
                                      java.lang.String name)