Package org.jruby

Class RubyThread.SleepTask2

java.lang.Object

org.jruby.RubyThread.SleepTask2

All Implemented Interfaces:

RubyThread.Task<Object,Long>, RubyThread.Unblocker<Object>

Enclosing class:

RubyThread

private static class RubyThread.SleepTask2
extends Object
implements RubyThread.Task<Object,Long>

A Task for sleeping. The Semaphore is immediately drained on construction, so that any subsequent acquire will block. The sleep is interrupted by releasing a permit. All permits are drained again on exit to ensure the next sleep blocks.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) long	millis
(package private) final Semaphore	semaphore

Constructor Summary

Constructors

Modifier	Constructor	Description
private	SleepTask2()

Method Summary

Modifier and Type	Method	Description
Long	run(ThreadContext context, Object data)
void	wakeup(RubyThread thread, Object data)

Methods inherited from class java.lang.Object

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

Field Details

semaphore

final Semaphore semaphore

millis

long millis

Constructor Details

SleepTask2

private SleepTask2()

Method Details

run

public Long run(ThreadContext context,
 Object data)
         throws InterruptedException

Specified by:

run in interface RubyThread.Task<Object,Long>

Throws:

InterruptedException

wakeup

public void wakeup(RubyThread thread,
 Object data)

Specified by:

wakeup in interface RubyThread.Task<Object,Long>

Specified by:

wakeup in interface RubyThread.Unblocker<Object>