Top Inners Fields Constructors Methods

org.jruby.ext.timeout

public Class Timeout

Nested and Inner Type Summary

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

Field Summary

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

Constructor Summary

Access	Constructor and Description
public	Timeout()

Method Summary

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

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

EXECUTOR_VARIABLE	back to summary
public static final String EXECUTOR_VARIABLE

TIMEOUT_MESSAGE	back to summary
private static final ByteList TIMEOUT_MESSAGE

Constructor Detail

Timeout	back to summary
public Timeout()

Method Detail

defaultTimeoutMessage	back to summary
private static RubyString defaultTimeoutMessage(final ThreadContext context)

getTimeoutError	back to summary
private static RubyClass getTimeoutError(ThreadContext context, final RubyModule timeout)

killTimeoutThread	back to summary
private static void killTimeoutThread(ThreadContext context, ScheduledFuture<V> timeoutFuture, AtomicBoolean latch)

load	back to summary
public static void load(Ruby runtime)

nilOrZeroSeconds	back to summary
private static boolean nilOrZeroSeconds(final ThreadContext context, final IRubyObject seconds)

raiseTimeoutErrorIfMatches	back to summary
private static IRubyObject raiseTimeoutErrorIfMatches(ThreadContext context, final RubyModule timeout, final RaiseException ex, final Object id)

timeout	back to summary
public static IRubyObject timeout(final ThreadContext context, IRubyObject recv, IRubyObject seconds, Block block) Annotations @JRubyMethod module:true

timeout	back to summary
public static IRubyObject timeout(final ThreadContext context, IRubyObject recv, IRubyObject seconds, IRubyObject exceptionType, Block block) Annotations @JRubyMethod module:true

timeout	back to summary
public static IRubyObject timeout(final ThreadContext context, IRubyObject recv, IRubyObject seconds, IRubyObject exceptionType, IRubyObject message, Block block) Annotations @JRubyMethod module:true

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

org.jruby.ext.timeout back to summary

private Class Timeout.TimeoutTask

Class Inheritance

extends Object
implements Runnable

java.lang.Object
org.jruby.ext.timeout.Timeout.TimeoutTask

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
pack-priv final RubyThread	currentThread
pack-priv final IRubyObject	exception
pack-priv final Object	id
pack-priv final AtomicBoolean	latch
pack-priv final RubyString	message
pack-priv final RubyModule	timeout

Constructor Summary

Access	Constructor and Description
private	TimeoutTask(final RubyThread currentThread, final RubyModule timeout, final AtomicBoolean latch, final Object id, final IRubyObject exception, final RubyString message)

Method Summary

Modifier and Type	Method and Description
pack-priv static Timeout.TimeoutTask	newAnonymousTask(final RubyThread currentThread, final RubyModule timeout, final AtomicBoolean latch, final Object id, final RubyString message)
pack-priv static Timeout.TimeoutTask	newTaskWithException(final RubyThread currentThread, final RubyModule timeout, final AtomicBoolean latch, final IRubyObject exception, final RubyString message)
private void	raiseAnonymous(ThreadContext context)
private void	raiseException()
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

currentThread	back to summary
pack-priv final RubyThread currentThread

exception	back to summary
pack-priv final IRubyObject exception

id	back to summary
pack-priv final Object id

latch	back to summary
pack-priv final AtomicBoolean latch

message	back to summary
pack-priv final RubyString message

timeout	back to summary
pack-priv final RubyModule timeout

Constructor Detail

TimeoutTask	back to summary
private TimeoutTask(final RubyThread currentThread, final RubyModule timeout, final AtomicBoolean latch, final Object id, final IRubyObject exception, final RubyString message)

Method Detail

newAnonymousTask	back to summary
pack-priv static Timeout.TimeoutTask newAnonymousTask(final RubyThread currentThread, final RubyModule timeout, final AtomicBoolean latch, final Object id, final RubyString message)

newTaskWithException	back to summary
pack-priv static Timeout.TimeoutTask newTaskWithException(final RubyThread currentThread, final RubyModule timeout, final AtomicBoolean latch, final IRubyObject exception, final RubyString message)

raiseAnonymous	back to summary
private void raiseAnonymous(ThreadContext context)

raiseException	back to summary
private void raiseException()

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.