Top Description Fields Constructors Methods

org.jruby.ext.fiber

public Class FiberQueue

Class Inheritance

extends Object

java.lang.Object
org.jruby.ext.fiber.FiberQueue

Imports

org.jruby.Ruby, .RubyThread, org.jruby.exceptions.RaiseException, org.jruby.ext.fiber.ThreadFiber.FiberRequest, org.jruby.runtime.ThreadContext, org.jruby.runtime.builtin.IRubyObject, java.util.concurrent.ArrayBlockingQueue, .BlockingQueue

A RubyThread-aware BlockingQueue wrapper used by Fiber for transferring values.

Field Summary

Modifier and Type	Field and Description
protected BlockingQueue<ThreadFiber.FiberRequest>	queue
protected final Ruby	runtime
private static final RubyThread.Task<FiberQueue, ThreadFiber.FiberRequest>	TAKE_TASK

Constructor Summary

Access	Constructor and Description
public	FiberQueue(Ruby runtime)

Method Summary

Modifier and Type	Method and Description
public synchronized void	checkShutdown()
public BlockingQueue<ThreadFiber.FiberRequest>	getQueueSafe()
public boolean	isShutdown()
public ThreadFiber.FiberRequest	pop(ThreadContext context)
public void	push(ThreadContext context, final ThreadFiber.FiberRequest arg)
public IRubyObject	shutdown(ThreadContext context)
public synchronized void	shutdown()

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

Field Detail

queue	back to summary
protected BlockingQueue<ThreadFiber.FiberRequest> queue

runtime	back to summary
protected final Ruby runtime

TAKE_TASK	back to summary
private static final RubyThread.Task<FiberQueue, ThreadFiber.FiberRequest> TAKE_TASK

Constructor Detail

FiberQueue	back to summary
public FiberQueue(Ruby runtime)

Method Detail

checkShutdown	back to summary
public synchronized void checkShutdown()

getQueueSafe	back to summary
public BlockingQueue<ThreadFiber.FiberRequest> getQueueSafe()

isShutdown	back to summary
public boolean isShutdown()

pop	back to summary
public ThreadFiber.FiberRequest pop(ThreadContext context)

push	back to summary
public void push(ThreadContext context, final ThreadFiber.FiberRequest arg)

shutdown	back to summary
public IRubyObject shutdown(ThreadContext context)

shutdown	back to summary
public synchronized void shutdown()