org.jruby.ext.timeout

Class Timeout.TimeoutTask

java.lang.Object

org.jruby.ext.timeout.Timeout.TimeoutTask

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

Timeout

private static class Timeout.TimeoutTask
extends java.lang.Object
implements java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field and Description
(package private) RubyThread	currentThread
(package private) IRubyObject	exception
(package private) IRubyObject	id
(package private) java.util.concurrent.atomic.AtomicBoolean	latch
(package private) IRubyObject	timeout

Constructor Summary

Constructors

Modifier	Constructor and Description
private	TimeoutTask(RubyThread currentThread, IRubyObject timeout, java.util.concurrent.atomic.AtomicBoolean latch, IRubyObject id, IRubyObject exception)

Method Summary

Modifier and Type	Method and Description
(package private) static Timeout.TimeoutTask	newAnnonymousTask(RubyThread currentThread, IRubyObject timeout, java.util.concurrent.atomic.AtomicBoolean latch, IRubyObject id)
(package private) static Timeout.TimeoutTask	newTaskWithException(RubyThread currentThread, IRubyObject timeout, java.util.concurrent.atomic.AtomicBoolean latch, IRubyObject exception)
private void	raiseAnnonymous()
private void	raiseException()
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

currentThread

final RubyThread currentThread

latch

final java.util.concurrent.atomic.AtomicBoolean latch

timeout

final IRubyObject timeout

id

final IRubyObject id

exception

final IRubyObject exception

Constructor Detail

TimeoutTask

private TimeoutTask(RubyThread currentThread,
                    IRubyObject timeout,
                    java.util.concurrent.atomic.AtomicBoolean latch,
                    IRubyObject id,
                    IRubyObject exception)

Method Detail

newAnnonymousTask

static Timeout.TimeoutTask newAnnonymousTask(RubyThread currentThread,
                                             IRubyObject timeout,
                                             java.util.concurrent.atomic.AtomicBoolean latch,
                                             IRubyObject id)

newTaskWithException

static Timeout.TimeoutTask newTaskWithException(RubyThread currentThread,
                                                IRubyObject timeout,
                                                java.util.concurrent.atomic.AtomicBoolean latch,
                                                IRubyObject exception)

run

public void run()

Specified by:

run in interface java.lang.Runnable

raiseAnnonymous

private void raiseAnnonymous()

raiseException

private void raiseException()