FiberQueue

java.lang.Object

org.jruby.ext.fiber.FiberQueue

public class FiberQueue extends Object

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

Field Summary

Fields

Modifier and Type

Field

Description

protected BlockingQueue<IRubyObject>

queue

protected final Ruby

runtime

(package private) final RubyThread.Task<FiberQueue,IRubyObject>

takeTask
Constructor Summary

Constructors

Constructor

Description

FiberQueue(Ruby runtime)
Method Summary

Modifier and Type

Method

Description

void

checkShutdown()

BlockingQueue<IRubyObject>

getQueueSafe()

boolean

isShutdown()

IRubyObject

pop(ThreadContext context)

void

push(ThreadContext context, IRubyObject arg)

void

shutdown()

IRubyObject

shutdown(ThreadContext context)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- queue
  
  protected BlockingQueue<IRubyObject> queue
- runtime
  
  protected final Ruby runtime
- takeTask
  
  final RubyThread.Task<FiberQueue,IRubyObject> takeTask
Constructor Details
- FiberQueue
  
  public FiberQueue(Ruby runtime)
Method Details
- shutdown
  
  public IRubyObject shutdown(ThreadContext context)
- shutdown
  
  public void shutdown()
- isShutdown
  
  public boolean isShutdown()
- getQueueSafe
  
  public BlockingQueue<IRubyObject> getQueueSafe()
- checkShutdown
  
  public void checkShutdown()
- pop
  
  public IRubyObject pop(ThreadContext context)
- push
  
  public void push(ThreadContext context, IRubyObject arg)