org.jruby

Class RubyEnumerator.ThreadedNexter

java.lang.Object

org.jruby.RubyEnumerator.Nexter

org.jruby.RubyEnumerator.ThreadedNexter

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

RubyEnumerator

private static class RubyEnumerator.ThreadedNexter
extends RubyEnumerator.Nexter
implements java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field and Description
private static boolean	DEBUG
protected boolean	die death mark
private IRubyObject	doneObject whether we're done iterating
private java.util.concurrent.Future	future future to cancel job if it has not started
private IRubyObject	lastValue the last value we got, used for peek
private java.util.concurrent.SynchronousQueue<IRubyObject>	out sync queue to wait for values
private java.lang.Thread	thread thread that's executing this Nexter

Fields inherited from class org.jruby.RubyEnumerator.Nexter

method, methodArgs, object, runtime

Constructor Summary

Constructors

Constructor and Description
ThreadedNexter(Ruby runtime, IRubyObject object, java.lang.String method, IRubyObject[] methodArgs)

Method Summary

Modifier and Type	Method and Description
private void	ensureStarted()
IRubyObject	next()
IRubyObject	peek()
private IRubyObject	peekTake()
private IRubyObject	returnValue(IRubyObject value)
void	run()
void	shutdown()
private IRubyObject	take()

Methods inherited from class java.lang.Object

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

Field Detail

DEBUG

private static final boolean DEBUG

See Also:

Constant Field Values

out

private java.util.concurrent.SynchronousQueue<IRubyObject> out

sync queue to wait for values

thread

private volatile java.lang.Thread thread

thread that's executing this Nexter

doneObject

private IRubyObject doneObject

whether we're done iterating

future

private java.util.concurrent.Future future

future to cancel job if it has not started

die

protected volatile boolean die

death mark

lastValue

private IRubyObject lastValue

the last value we got, used for peek

Constructor Detail

ThreadedNexter

public ThreadedNexter(Ruby runtime,
                      IRubyObject object,
                      java.lang.String method,
                      IRubyObject[] methodArgs)

Method Detail

next

public IRubyObject next()

Specified by:

next in class RubyEnumerator.Nexter

shutdown

public void shutdown()

Specified by:

shutdown in class RubyEnumerator.Nexter

peek

public IRubyObject peek()

Specified by:

peek in class RubyEnumerator.Nexter

ensureStarted

private void ensureStarted()

peekTake

private IRubyObject peekTake()

take

private IRubyObject take()

returnValue

private IRubyObject returnValue(IRubyObject value)

run

public void run()

Specified by:

run in interface java.lang.Runnable