Nested and Inner Type Summary

Modifier and Type	Class and Description
public static class	ThreadFiber.FiberData
public static class	ThreadFiber.FiberRequest
public static class	ThreadFiber.FiberSchedulerSupport
public static enum	ThreadFiber.RequestType
private static class	ThreadFiber.VirtualThreadLauncher

Field Summary

Modifier and Type	Field and Description
pack-priv volatile ThreadFiber.FiberData	data
private static final BiConsumer<Ruby, Runnable>	FIBER_LAUNCHER
private static final String[]	INITIALIZE_KWARGS
private static final Logger	LOG
private static final ThreadFiber.FiberRequest	NEVER Hides org.jruby.RubyBasicObject.NEVER.
pack-priv final boolean	root
pack-priv RubyHash	storage
pack-priv volatile RubyThread	thread
private static final MethodHandle	VTHREAD_START_METHOD

Inherited from org.jruby.RubyObject:: IVAR_INSPECTING_OBJECT_ALLOCATOR OBJECT_ALLOCATOR REIFYING_OBJECT_ALLOCATOR

Constructor Summary

Access	Constructor and Description
public	ThreadFiber(Ruby runtime, RubyClass klass)
public	ThreadFiber(Ruby runtime, RubyClass klass, boolean root)

Method Summary

Modifier and Type	Method and Description
public IRubyObject	__finalize__(ThreadContext context)
private static void	adjustThreadBlocking(ThreadContext context, ThreadFiber.FiberData currentFiberData, ThreadFiber.FiberData targetFiberData)
pack-priv final boolean	alive()
public IRubyObject	alive_p(ThreadContext context)
public IRubyObject	backtrace(ThreadContext context)
public IRubyObject	backtrace(ThreadContext context, IRubyObject level)
public IRubyObject	backtrace(ThreadContext context, IRubyObject level, IRubyObject length)
public IRubyObject	backtrace_locations(ThreadContext context)
public IRubyObject	backtrace_locations(ThreadContext context, IRubyObject level)
public IRubyObject	backtrace_locations(ThreadContext context, IRubyObject level, IRubyObject length)
public static IRubyObject	blocking(ThreadContext context, IRubyObject self, Block block)
public IRubyObject	blocking_p(ThreadContext context)
public static IRubyObject	blocking_p_s(ThreadContext context, IRubyObject self)
private void	checkSameFiber(ThreadContext context)
pack-priv static RubyThread	createThread(ThreadContext context, final ThreadFiber.FiberData data, final FiberQueue queue, final Block block)
public static IRubyObject	current(ThreadContext context, IRubyObject recv)
private void	doFinalize()
private static ThreadFiber.FiberRequest	exchangeWithFiber(ThreadContext context, ThreadFiber.FiberData currentFiberData, ThreadFiber.FiberData targetFiberData, ThreadFiber.FiberRequest request)
private static void	fiberCalledAcrossThreads(Ruby runtime)
protected void	finalize() Overrides java.lang.Object.finalize. Called by the garbage collector on an object when garbage collection determines that there are no more references to the object.
public Map<Object, IRubyObject>	getContextVariables() Implements org.jruby.runtime.ExecutionContext.getContextVariables.
public ThreadFiber.FiberData	getData()
public RubyThread	getThread()
private static void	handleExceptionDuringExchange(ThreadContext context, ThreadFiber.FiberData currentFiberData, ThreadFiber.FiberData targetFiberData, RaiseException re) Handle exceptions raised while exchanging data with a fiber.
public void	inheritFiberStorage(ThreadContext context)
public IRubyObject	initialize(ThreadContext context, Block block)
public IRubyObject	initialize(ThreadContext context, IRubyObject _opts, Block block)
public static void	initRootFiber(ThreadContext context, RubyThread currentThread)
public boolean	isBlocking()
public IRubyObject	kill(ThreadContext context)
private static void	nativeThreadLauncher(Ruby runtime, Runnable runnable)
public static IRubyObject	op_aref(ThreadContext context, IRubyObject recv, IRubyObject key)
public static IRubyObject	op_aset(ThreadContext context, IRubyObject recv, IRubyObject key, IRubyObject value)
private static IRubyObject	processResultData(ThreadContext context, ThreadFiber.FiberRequest result)
public IRubyObject	raise(ThreadContext context, IRubyObject[] args)
public IRubyObject	raise(ThreadContext context, IRubyObject exception)
public IRubyObject	resume(ThreadContext context, IRubyObject[] values)
private void	setStorage(ThreadContext context, IRubyObject hash)
public IRubyObject	storage(ThreadContext context)
public IRubyObject	storage_set(ThreadContext context, IRubyObject hash)
public IRubyObject	transfer(ThreadContext context, IRubyObject[] values)
private static void	validateStorage(ThreadContext context, IRubyObject hashArg)
private static ThreadFiber.FiberData	verifyCurrentFiber(ThreadContext context, Ruby runtime)
public static IRubyObject	yield(ThreadContext context, IRubyObject recv)
public static IRubyObject	yield(ThreadContext context, IRubyObject recv, IRubyObject value)
public static IRubyObject	yield(ThreadContext context, IRubyObject recv, IRubyObject[] value)

Field Detail

data	back to summary
pack-priv volatile ThreadFiber.FiberData data

FIBER_LAUNCHER	back to summary
private static final BiConsumer<Ruby, Runnable> FIBER_LAUNCHER

INITIALIZE_KWARGS	back to summary
private static final String[] INITIALIZE_KWARGS

LOG	back to summary
private static final Logger LOG

NEVER	back to summary
private static final ThreadFiber.FiberRequest NEVER Hides org.jruby.RubyBasicObject.NEVER.

root	back to summary
pack-priv final boolean root

storage	back to summary
pack-priv RubyHash storage

thread	back to summary
pack-priv volatile RubyThread thread

VTHREAD_START_METHOD	back to summary
private static final MethodHandle VTHREAD_START_METHOD

Constructor Detail

ThreadFiber	back to summary
public ThreadFiber(Ruby runtime, RubyClass klass)

ThreadFiber	back to summary
public ThreadFiber(Ruby runtime, RubyClass klass, boolean root)

Method Detail

__finalize__	back to summary
public IRubyObject __finalize__(ThreadContext context) Annotations @JRubyMethod visibility:PRIVATE

adjustThreadBlocking	back to summary
private static void adjustThreadBlocking(ThreadContext context, ThreadFiber.FiberData currentFiberData, ThreadFiber.FiberData targetFiberData)

alive	back to summary
pack-priv final boolean alive()

alive_p	back to summary
public IRubyObject alive_p(ThreadContext context) Annotations @JRubyMethod name:alive?

backtrace	back to summary
public IRubyObject backtrace(ThreadContext context) Annotations @JRubyMethod name:backtrace

backtrace	back to summary
public IRubyObject backtrace(ThreadContext context, IRubyObject level) Annotations @JRubyMethod name:backtrace

backtrace	back to summary
public IRubyObject backtrace(ThreadContext context, IRubyObject level, IRubyObject length) Annotations @JRubyMethod name:backtrace

backtrace_locations	back to summary
public IRubyObject backtrace_locations(ThreadContext context) Annotations @JRubyMethod name:backtrace_locations

backtrace_locations	back to summary
public IRubyObject backtrace_locations(ThreadContext context, IRubyObject level) Annotations @JRubyMethod name:backtrace_locations

backtrace_locations	back to summary
public IRubyObject backtrace_locations(ThreadContext context, IRubyObject level, IRubyObject length) Annotations @JRubyMethod name:backtrace_locations

blocking	back to summary
public static IRubyObject blocking(ThreadContext context, IRubyObject self, Block block) Annotations @JRubyMethod name:blocking meta:true

blocking_p	back to summary
public IRubyObject blocking_p(ThreadContext context) Annotations @JRubyMethod name:blocking?

blocking_p_s	back to summary
public static IRubyObject blocking_p_s(ThreadContext context, IRubyObject self) Annotations @JRubyMethod name:blocking? meta:true

checkSameFiber	back to summary
private void checkSameFiber(ThreadContext context)

createThread	back to summary
pack-priv static RubyThread createThread(ThreadContext context, final ThreadFiber.FiberData data, final FiberQueue queue, final Block block)

current	back to summary
public static IRubyObject current(ThreadContext context, IRubyObject recv) Annotations @JRubyMethod meta:true

doFinalize	back to summary
private void doFinalize()

exchangeWithFiber	back to summary
private static ThreadFiber.FiberRequest exchangeWithFiber(ThreadContext context, ThreadFiber.FiberData currentFiberData, ThreadFiber.FiberData targetFiberData, ThreadFiber.FiberRequest request)

fiberCalledAcrossThreads	back to summary
private static void fiberCalledAcrossThreads(Ruby runtime)

finalize back to summary

finalize	back to summary
protected void finalize() throws Throwable Overrides java.lang.Object.finalize. Doc from java.lang.Object.finalize. Called by the garbage collector on an object when garbage collection determines that there are no more references to the object. A subclass overrides the `finalize` method to dispose of system resources or to perform other cleanup. When running in a Java virtual machine in which finalization has been disabled or removed, the garbage collector will never call `finalize()`. In a Java virtual machine in which finalization is enabled, the garbage collector might call `finalize` only after an indefinite delay. The general contract of `finalize` is that it is invoked if and when the Java virtual machine has determined that there is no longer any means by which this object can be accessed by any thread that has not yet died, except as a result of an action taken by the finalization of some other object or class which is ready to be finalized. The `finalize` method may take any action, including making this object available again to other threads; the usual purpose of `finalize`, however, is to perform cleanup actions before the object is irrevocably discarded. For example, the finalize method for an object that represents an input/output connection might perform explicit I/O transactions to break the connection before the object is permanently discarded. The `finalize` method of class `Object` performs no special action; it simply returns normally. Subclasses of `Object` may override this definition. The Java programming language does not guarantee which thread will invoke the `finalize` method for any given object. It is guaranteed, however, that the thread that invokes finalize will not be holding any user-visible synchronization locks when finalize is invoked. If an uncaught exception is thrown by the finalize method, the exception is ignored and finalization of that object terminates. After the `finalize` method has been invoked for an object, no further action is taken until the Java virtual machine has again determined that there is no longer any means by which this object can be accessed by any thread that has not yet died, including possible actions by other objects or classes which are ready to be finalized, at which point the object may be discarded. The `finalize` method is never invoked more than once by a Java virtual machine for any given object. Any exception thrown by the `finalize` method causes the finalization of this object to be halted, but is otherwise ignored. Annotations @Override Exceptions Throwable: the `Exception` raised by this method

protected void finalize() throws Throwable

Overrides java.lang.Object.finalize.

Doc from java.lang.Object.finalize.

Called by the garbage collector on an object when garbage collection determines that there are no more references to the object. A subclass overrides the finalize method to dispose of system resources or to perform other cleanup.

When running in a Java virtual machine in which finalization has been disabled or removed, the garbage collector will never call finalize(). In a Java virtual machine in which finalization is enabled, the garbage collector might call finalize only after an indefinite delay.

The general contract of finalize is that it is invoked if and when the Java virtual machine has determined that there is no longer any means by which this object can be accessed by any thread that has not yet died, except as a result of an action taken by the finalization of some other object or class which is ready to be finalized. The finalize method may take any action, including making this object available again to other threads; the usual purpose of finalize, however, is to perform cleanup actions before the object is irrevocably discarded. For example, the finalize method for an object that represents an input/output connection might perform explicit I/O transactions to break the connection before the object is permanently discarded.

The finalize method of class Object performs no special action; it simply returns normally. Subclasses of Object may override this definition.

The Java programming language does not guarantee which thread will invoke the finalize method for any given object. It is guaranteed, however, that the thread that invokes finalize will not be holding any user-visible synchronization locks when finalize is invoked. If an uncaught exception is thrown by the finalize method, the exception is ignored and finalization of that object terminates.

After the finalize method has been invoked for an object, no further action is taken until the Java virtual machine has again determined that there is no longer any means by which this object can be accessed by any thread that has not yet died, including possible actions by other objects or classes which are ready to be finalized, at which point the object may be discarded.

The finalize method is never invoked more than once by a Java virtual machine for any given object.

Any exception thrown by the finalize method causes the finalization of this object to be halted, but is otherwise ignored.

Annotations

@Override

Exceptions

Throwable:: the Exception raised by this method

getContextVariables	back to summary
public Map<Object, IRubyObject> getContextVariables() Implements org.jruby.runtime.ExecutionContext.getContextVariables. Annotations @Override

getContextVariables

back to summary

public Map<Object, IRubyObject> getContextVariables()

Implements org.jruby.runtime.ExecutionContext.getContextVariables.

Annotations

@Override

getData	back to summary
public ThreadFiber.FiberData getData()

getThread	back to summary
public RubyThread getThread()

handleExceptionDuringExchange	back to summary
private static void handleExceptionDuringExchange(ThreadContext context, ThreadFiber.FiberData currentFiberData, ThreadFiber.FiberData targetFiberData, RaiseException re) Handle exceptions raised while exchanging data with a fiber. The rules work like this: If the thread has called Fiber#resume on the fiber and an interrupt is sent to the thread, forward it to the fiber If the fiber has called Fiber.yield and an interrupt is sent to the fiber (e.g. Timeout.timeout(x) { Fiber.yield }) forward it to the fiber's parent thread.

handleExceptionDuringExchange

back to summary

private static void handleExceptionDuringExchange(ThreadContext context, ThreadFiber.FiberData currentFiberData, ThreadFiber.FiberData targetFiberData, RaiseException re)

Handle exceptions raised while exchanging data with a fiber. The rules work like this:

If the thread has called Fiber#resume on the fiber and an interrupt is sent to the thread, forward it to the fiber
If the fiber has called Fiber.yield and an interrupt is sent to the fiber (e.g. Timeout.timeout(x) { Fiber.yield }) forward it to the fiber's parent thread.

inheritFiberStorage	back to summary
public void inheritFiberStorage(ThreadContext context)

initialize	back to summary
public IRubyObject initialize(ThreadContext context, Block block) Annotations @JRubyMethod visibility:PRIVATE

initialize	back to summary
public IRubyObject initialize(ThreadContext context, IRubyObject _opts, Block block) Annotations @JRubyMethod visibility:PRIVATE

initRootFiber	back to summary
public static void initRootFiber(ThreadContext context, RubyThread currentThread)

isBlocking	back to summary
public boolean isBlocking()

kill	back to summary
public IRubyObject kill(ThreadContext context) Annotations @JRubyMethod

nativeThreadLauncher	back to summary
private static void nativeThreadLauncher(Ruby runtime, Runnable runnable)

op_aref	back to summary
public static IRubyObject op_aref(ThreadContext context, IRubyObject recv, IRubyObject key) Annotations @JRubyMethod name:[] meta:true

op_aset	back to summary
public static IRubyObject op_aset(ThreadContext context, IRubyObject recv, IRubyObject key, IRubyObject value) Annotations @JRubyMethod name:[]= meta:true

processResultData	back to summary
private static IRubyObject processResultData(ThreadContext context, ThreadFiber.FiberRequest result)

raise	back to summary
public IRubyObject raise(ThreadContext context, IRubyObject[] args) Annotations @JRubyMethod rest:true

raise	back to summary
public IRubyObject raise(ThreadContext context, IRubyObject exception)

resume	back to summary
public IRubyObject resume(ThreadContext context, IRubyObject[] values) Annotations @JRubyMethod rest:true keywords:true

setStorage	back to summary
private void setStorage(ThreadContext context, IRubyObject hash)

storage	back to summary
public IRubyObject storage(ThreadContext context) Annotations @JRubyMethod

storage_set	back to summary
public IRubyObject storage_set(ThreadContext context, IRubyObject hash) Annotations @JRubyMethod name:storage=

transfer	back to summary
public IRubyObject transfer(ThreadContext context, IRubyObject[] values) Annotations @JRubyMethod rest:true

validateStorage	back to summary
private static void validateStorage(ThreadContext context, IRubyObject hashArg)

verifyCurrentFiber	back to summary
private static ThreadFiber.FiberData verifyCurrentFiber(ThreadContext context, Ruby runtime)

yield	back to summary
public static IRubyObject yield(ThreadContext context, IRubyObject recv) Annotations @JRubyMethod meta:true

yield	back to summary
public static IRubyObject yield(ThreadContext context, IRubyObject recv, IRubyObject value) Annotations @JRubyMethod meta:true

yield	back to summary
public static IRubyObject yield(ThreadContext context, IRubyObject recv, IRubyObject[] value) Annotations @JRubyMethod meta:true rest:true

org.jruby.ext.fiber back to summary

public Class ThreadFiber.FiberData

Class Inheritance

extends Object

java.lang.Object
org.jruby.ext.fiber.ThreadFiber.FiberData

Field Summary

Modifier and Type	Field and Description
pack-priv volatile boolean	blocking
pack-priv final WeakReference<ThreadFiber>	fiber
pack-priv final RubyThread	parent
pack-priv volatile ThreadFiber	prev
pack-priv final FiberQueue	queue
pack-priv volatile boolean	transferred

Constructor Summary

Access	Constructor and Description
pack-priv	FiberData(FiberQueue queue, RubyThread parent, ThreadFiber fiber, boolean blocking)

Method Summary

Modifier and Type	Method and Description
public ThreadFiber	getPrev()

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

Field Detail

blocking	back to summary
pack-priv volatile boolean blocking

fiber	back to summary
pack-priv final WeakReference<ThreadFiber> fiber

parent	back to summary
pack-priv final RubyThread parent

prev	back to summary
pack-priv volatile ThreadFiber prev

queue	back to summary
pack-priv final FiberQueue queue

transferred	back to summary
pack-priv volatile boolean transferred

Constructor Detail

FiberData	back to summary
pack-priv FiberData(FiberQueue queue, RubyThread parent, ThreadFiber fiber, boolean blocking)

Method Detail

getPrev	back to summary
public ThreadFiber getPrev()

org.jruby.ext.fiber back to summary

public Class ThreadFiber.FiberRequest

Class Inheritance

extends Object

java.lang.Object
org.jruby.ext.fiber.ThreadFiber.FiberRequest

Field Summary

Modifier and Type	Field and Description
pack-priv final Object	data
pack-priv final ThreadFiber.RequestType	type

Constructor Summary

Access	Constructor and Description
pack-priv	FiberRequest(Object data, ThreadFiber.RequestType type)

Method Summary

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

Field Detail

data	back to summary
pack-priv final Object data

type	back to summary
pack-priv final ThreadFiber.RequestType type

Constructor Detail

FiberRequest	back to summary
pack-priv FiberRequest(Object data, ThreadFiber.RequestType type)

org.jruby.ext.fiber back to summary

public Class ThreadFiber.FiberSchedulerSupport

Class Inheritance

extends Object

java.lang.Object
org.jruby.ext.fiber.ThreadFiber.FiberSchedulerSupport

Constructor Summary

Access	Constructor and Description
public	FiberSchedulerSupport()

Method Summary

Modifier and Type	Method and Description
public static IRubyObject	current_scheduler(ThreadContext context, IRubyObject self)
public static IRubyObject	get_scheduler(ThreadContext context, IRubyObject self)
public static IRubyObject	schedule(ThreadContext context, IRubyObject self, IRubyObject[] args, Block block)
public static IRubyObject	set_scheduler(ThreadContext context, IRubyObject self, IRubyObject scheduler)

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

Constructor Detail

FiberSchedulerSupport	back to summary
public FiberSchedulerSupport()

Method Detail

current_scheduler	back to summary
public static IRubyObject current_scheduler(ThreadContext context, IRubyObject self) Annotations @JRubyMethod name:current_scheduler meta:true

get_scheduler	back to summary
public static IRubyObject get_scheduler(ThreadContext context, IRubyObject self) Annotations @JRubyMethod name:scheduler meta:true

schedule	back to summary
public static IRubyObject schedule(ThreadContext context, IRubyObject self, IRubyObject[] args, Block block) Annotations @JRubyMethod name:schedule meta:true rest:true keywords:true

set_scheduler	back to summary
public static IRubyObject set_scheduler(ThreadContext context, IRubyObject self, IRubyObject scheduler) Annotations @JRubyMethod name:set_scheduler meta:true

org.jruby.ext.fiber back to summary

public final Enum ThreadFiber.RequestType

Class Inheritance

extends Enum<ThreadFiber.RequestType>

java.lang.Object
java.lang.Enum
org.jruby.ext.fiber.ThreadFiber.RequestType

Field Summary

Modifier and Type	Field and Description
public static final ThreadFiber.RequestType	DATA
public static final ThreadFiber.RequestType	RAISE

Constructor Summary

Access	Constructor and Description
private	RequestType()

Method Summary

Modifier and Type	Method and Description
public static ThreadFiber.RequestType	valueOf(String name)
public static ThreadFiber.RequestType[]	values()

Inherited from java.lang.Enum:: clone compareTo describeConstable equals finalize getDeclaringClass hashCode name ordinal toString valueOf

Field Detail

DATA	back to summary
public static final ThreadFiber.RequestType DATA

RAISE	back to summary
public static final ThreadFiber.RequestType RAISE

Constructor Detail

RequestType	back to summary
private RequestType()

Method Detail

valueOf	back to summary
public static ThreadFiber.RequestType valueOf(String name)

values	back to summary
public static ThreadFiber.RequestType[] values()

org.jruby.ext.fiber back to summary

private Class ThreadFiber.VirtualThreadLauncher

Class Inheritance

extends Object
implements BiConsumer<Ruby, Runnable>

java.lang.Object
org.jruby.ext.fiber.ThreadFiber.VirtualThreadLauncher

All Implemented Interfaces

java.util.function.BiConsumer

Constructor Summary

Access	Constructor and Description
private	VirtualThreadLauncher()

Method Summary

Modifier and Type	Method and Description
public void	accept(Ruby the first input argument ruby, Runnable the second input argument runnable) Implements java.util.function.BiConsumer.accept. Performs this operation on the given arguments.

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

Constructor Detail

VirtualThreadLauncher	back to summary
private VirtualThreadLauncher()

Method Detail

back to summary

public void accept(Ruby ruby, Runnable runnable)

Implements java.util.function.BiConsumer.accept.

Doc from java.util.function.BiConsumer.accept.

Performs this operation on the given arguments.

Parameters

ruby:Ruby: the first input argument
runnable:Runnable: the second input argument

Annotations

@Override