Package org.jruby.ext.thread

Class SizedQueue

java.lang.Object

org.jruby.RubyBasicObject

org.jruby.RubyObject

org.jruby.ext.thread.Queue

org.jruby.ext.thread.SizedQueue

All Implemented Interfaces:

Serializable, Cloneable, Comparable<IRubyObject>, InstanceVariables, InternalVariables, IRubyObject, CoreObjectType, DataType

public class SizedQueue
extends Queue

The "SizedQueue" class from the 'thread' library.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.jruby.ext.thread.Queue

Queue.Node

Nested classes/interfaces inherited from class org.jruby.RubyObject

RubyObject.Data

Nested classes/interfaces inherited from class org.jruby.RubyBasicObject

RubyBasicObject.Finalizer

Field Summary

Fields

Modifier and Type	Field	Description
private final RubyThread.Task<IRubyObject,IRubyObject>	blockingPushTask
private final RubyThread.Task<IRubyObject,IRubyObject>	nonblockingPushTask

Fields inherited from class org.jruby.ext.thread.Queue

capacity, closed, count, head, last, notEmpty, notFull, putLock, takeLock

Fields inherited from class org.jruby.RubyObject

IVAR_INSPECTING_OBJECT_ALLOCATOR, OBJECT_ALLOCATOR, REIFYING_OBJECT_ALLOCATOR

Fields inherited from class org.jruby.RubyBasicObject

ALL_F, BASICOBJECT_ALLOCATOR, COMPARE_BY_IDENTITY_F, ERR_INSECURE_SET_INST_VAR, FALSE_F, FL_USHIFT, flags, FROZEN_F, IS_OVERLAID_F, metaClass, NEVER, NIL_F, REFINED_MODULE_F, STAMP_OFFSET, TAINTED_F, UNDEF, UNTRUST_F, USER0_F, USER1_F, USER2_F, USER3_F, USER4_F, USER5_F, USER6_F, USER7_F, USER8_F, USER9_F, USERA_F, VAR_TABLE_OFFSET, varTable, varTableStamp

Fields inherited from interface org.jruby.runtime.builtin.IRubyObject

NULL_ARRAY

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SizedQueue(Ruby runtime, RubyClass type)
	SizedQueue(Ruby runtime, RubyClass type, int max)

Method Summary

Modifier and Type	Method	Description
IRubyObject	initialize(ThreadContext context, IRubyObject arg)
RubyNumeric	max(ThreadContext context)
IRubyObject	max_set(ThreadContext context, IRubyObject arg)
RubyNumeric	num_waiting(ThreadContext context)
protected boolean	offerInternal(ThreadContext context, IRubyObject e)
IRubyObject	push(ThreadContext context, IRubyObject[] argv)
static RubyClass	setup(RubyClass threadClass, RubyClass queueClass, RubyClass objectClass)
private static boolean	shouldBlock(ThreadContext context, IRubyObject[] argv)

Methods inherited from class org.jruby.ext.thread.Queue

checkShutdown, clear, clearInternal, close, closed_p, closeInternal, createInterruptedError, dequeue, empty_p, enqueue, fullyLock, fullyUnlock, initialize, initializedCheck, isShutdown, java_length, length, marshal_dump, pollInternal, pop, pop, push, putInternal, raiseClosedError, setup, setupError, shutdown, signalNotEmpty, signalNotFull, takeInternal

Methods inherited from class org.jruby.RubyObject

attachToObjectSpace, callInit, callInit, callInit, callInit, callInit, callInit, callInit, callInit, callInit, callInit, convertToType, createObjectClass, dig, dig1, dig2, eqlInternal, equalInternal, equals, getNativeClassIndex, hashCode, inspect, op_eqq, puts, specificEval, toRubyString, toString

Methods inherited from class org.jruby.RubyBasicObject

addFinalizer, anyToString, asJavaString, asString, callMethod, callMethod, callMethod, callMethod, callMethod, callMethod, callMethod, callMethod, callMethod, callSuper, checkArrayType, checkCallMethod, checkCallMethod, checkFrozen, checkStringType, checkStringType19, compareTo, convertToArray, convertToFloat, convertToHash, convertToInteger, convertToInteger, convertToInteger, convertToString, copyInstanceVariablesInto, copySpecialInstanceVariables, createBasicObjectClass, dataGetStruct, dataGetStructChecked, dataWrapStruct, decode, display, dup, ensureInstanceVariablesSettable, eql, eql_p, equal_p, equal_p19, evalUnder, extend, fastGetInstanceVariable, fastGetInternalVariable, fastHasInstanceVariable, fastHasInternalVariable, fastSetInstanceVariable, fastSetInternalVariable, freeze, frozen_p, getFFIHandle, getFlag, getInstanceEvalClass, getInstanceVariable, getInstanceVariableList, getInstanceVariableNameList, getInstanceVariables, getInternalVariable, getInternalVariables, getJavaClass, getMetaClass, getMetaClass, getNativeHandle, getNativeTypeIndex, getObjectId, getRuntime, getSingletonClass, getSingletonClassClone, getSingletonClassCloneAndAttach, getType, getVariable, getVariableCount, getVariableList, getVariableNameList, hash, hashyInspect, hasInstanceVariable, hasInstanceVariables, hasInternalVariable, hasVariables, id, infectBy, initialize_copy, initialize19, inspect, inspectHashCode, instance_eval, instance_eval, instance_eval, instance_eval, instance_eval19, instance_eval19, instance_eval19, instance_eval19, instance_exec, instance_exec19, instance_of_p, instance_variable_defined_p, instance_variable_get, instance_variable_set, instance_variables, instance_variables19, isBuiltin, isClass, isFalse, isFrozen, isImmediate, isModule, isNil, isSpecialConst, isSpecialObject, isTaint, isTrue, isUntrusted, kind_of_p, makeMetaClass, method, method_missing, method_missing19, method19, methods, methods, methods19, nil_p, nonFixnumHashCode, OBJ_INIT_COPY, objInitCopy, op_cmp, op_equal, op_equal_19, op_match, op_match19, op_not, op_not_equal, op_not_match, private_methods, private_methods19, protected_methods, protected_methods19, public_methods, public_methods19, rbClone, rbClone, rbInspect, remove_instance_variable, removeFinalizers, removeInstanceVariable, removeInternalVariable, respond_to_p, respond_to_p, respond_to_p19, respond_to_p19, respondsTo, respondsToMissing, respondsToMissing, send, send, send, send, send, send19, send19, send19, send19, setFFIHandle, setFlag, setFrozen, setInstanceVariable, setInternalVariable, setMetaClass, setNativeHandle, setTaint, setUntrusted, setVariable, singleton_method, singleton_method_added, singleton_method_added19, singleton_method_removed, singleton_method_removed19, singleton_method_undefined, singleton_method_undefined19, singleton_methods, specificEval, specificEval, specificEval, specificEval, syncVariables, syncVariables, taint, taint, tainted_p, testFrozen, testFrozen, to_a, to_a, to_s, toJava, trust, type, type_deprecated, untaint, untrust, untrusted_p, validateInstanceVariable, validateInstanceVariable, validateInstanceVariable, variableTableContains, variableTableFastContains, variableTableFastFetch, variableTableFastStore, variableTableFetch, variableTableRemove, variableTableStore, variableTableSync, yieldUnder, yieldUnder

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

blockingPushTask

private final RubyThread.Task<IRubyObject,IRubyObject> blockingPushTask

nonblockingPushTask

private final RubyThread.Task<IRubyObject,IRubyObject> nonblockingPushTask

Constructor Details

SizedQueue

protected SizedQueue(Ruby runtime,
 RubyClass type)

SizedQueue

public SizedQueue(Ruby runtime,
 RubyClass type,
 int max)

Method Details

setup

public static RubyClass setup(RubyClass threadClass,
 RubyClass queueClass,
 RubyClass objectClass)

max

public RubyNumeric max(ThreadContext context)

max_set

public IRubyObject max_set(ThreadContext context,
 IRubyObject arg)

initialize

public IRubyObject initialize(ThreadContext context,
 IRubyObject arg)

num_waiting

public RubyNumeric num_waiting(ThreadContext context)

Overrides:

num_waiting in class Queue

push

public IRubyObject push(ThreadContext context,
 IRubyObject[] argv)

offerInternal

protected boolean offerInternal(ThreadContext context,
 IRubyObject e)

shouldBlock

private static boolean shouldBlock(ThreadContext context,
 IRubyObject[] argv)