jruby/docs BETA
Navigation
org.jruby.internal.runtime 14
C AbstractIRMethod
C AdoptedNativeThread
C GlobalVariable
C GlobalVariables
I InternalSplitState
C ReadonlyAccessor
C RubyNativeThread
C RubyRunnable
C SplitSuperState
I ThreadLike
C ThreadService
I ThreadedRunnable
C UndefinedAccessor
C ValueAccessor
ThreadService — members 13+
C new(runtime)
M active_ruby_threads() RubyThread[]
C associate_thread(thread, ruby_thread)
M current_context() ThreadContext
M get_current_context(service) ThreadContext
M increment_and_get_thread_count() long
C init_main_thread()
M main_thread() RubyThread
M register_new_thread(thread) ThreadContext
C set_main_thread(thread, ruby_thread)
C teardown()
C unregister_current_thread(context)
C unregister_thread(thread)
from ThreadLocal
M get() T
C remove()
C set(arg0)

org.jruby.internal.runtime.ThreadService

class extends ThreadLocal<SoftReference<ThreadContext>> 13 members

ThreadService maintains references to all JRuby-specific thread data structures needed for Ruby's threading API and for JRuby's execution. The main structures are:

  • ThreadContext, which contains frames, scopes, etc needed for Ruby execution
  • RubyThread, the Ruby object representation of a thread's state
  • RubyThreadGroup, which represents a group of Ruby threads
  • RubyNativeThread, used to wrap threads owned by the current Ruby runtime
  • AdoptedNativeThread, used to wrap threads managed outside of JRuby
In order to ensure these structures do not linger after the thread has terminated, most of them are either weakly or softly referenced. The references associated with these structures are:
  • ThreadService is itself a ThreadLocal, which holds a soft reference to a ThreadContext. So the thread's locals softly reference ThreadContext. We use a soft reference to keep ThreadContext instances from going away too quickly when a Java thread leaves Ruby space completely, which would otherwise result in a lot of ThreadContext object churn.
  • ThreadService maintains a weak map from the actual java.lang.Thread instance to the associated RubyThread. The map is weak-keyyed, so it will not prevent the collection of the associated Thread. The associated RubyThread will remain alive as long as the Thread and this ThreadService instance are both alive, maintaining the external thread's identity in Ruby-land.
  • RubyThread has a weak reference to its to ThreadContext.
  • ThreadContext has a hard reference to its associated RubyThread. Ignoring other references, this will usually mean RubyThread is softly reachable via the soft threadlocal reference to ThreadContext in ThreadService.
  • RubyThreadGroup has hard references to threads it owns. The thread removes itself on termination (if it's a Ruby thread) or when the ThreadContext is collected (as in the case of "adopted" Java threads.
These data structures can come to life in one of two ways:
  • A Ruby thread is started. This constructs a new RubyThread object, which calls to ThreadService to initialize a ThreadContext and appropriate mappings in all ThreadService's structures. The body of the thread is wrapped with a finally block that will forcibly unregister the thread and all related structures from ThreadService.
  • A Java thread enters Ruby by doing a call. The thread is "adopted", and gains a RubyThread instance, a ThreadContext instance, and all associated mappings in ThreadService. Since we don't know when the thread has "left" Ruby permanently, no forcible unregistration is attempted for the various structures and maps. However, they should not be hard-rooted; the ThreadContext is only softly reachable at best if no calls are in-flight, so it will collect. Its collection will release the reference to RubyThread, and its finalizer will unregister that RubyThread from its RubyThreadGroup. With the RubyThread gone, the Thread-to-RubyThread map will eventually clear, releasing the hard reference to the Thread itself.

Constructors

new

new ( Ruby runtime )
Java: <init>(org.jruby.Ruby runtime)

Class Methods

get_current_context

ThreadContext get_current_context ( ThreadService service )
Java: getCurrentContext(org.jruby.internal.runtime.ThreadService service)

Instance Methods

active_ruby_threads

RubyThread[] active_ruby_threads ( )
Java: getActiveRubyThreads() · also: get_active_ruby_threads

associate_thread

associate_thread ( Thread thread, RubyThread ruby_thread )
Java: associateThread(Thread thread, org.jruby.RubyThread rubyThread)

current_context

ThreadContext current_context ( )
Java: getCurrentContext() · also: get_current_context

In order to provide an appropriate execution context for a given thread, we store ThreadContext instances in a threadlocal. This method is a utility to get at that threadlocal context from anywhere in the program it may not be immediately available. This method should be used sparingly, and if it is possible to pass ThreadContext on the argument list, it is preferable. Description of behavior The threadlocal does not actually contain the ThreadContext directly; instead, it contains a SoftReference that holds the ThreadContext. This is to allow new threads to enter the system and execute Ruby code with a valid context, but still allow that context to garbage collect if the thread stays alive much longer. We use SoftReference here because WeakReference is collected too quickly, resulting in very expensive ThreadContext churn (and this originally lead to JRUBY-2261's leak of adopted RubyThread instances).

Returns: The ThreadContext instance for the current thread, or a new one if none has previously been created or the old ThreadContext has been collected.

increment_and_get_thread_count

long increment_and_get_thread_count ( )
Java: incrementAndGetThreadCount()

init_main_thread

init_main_thread ( )
Java: initMainThread()

main_thread

RubyThread main_thread ( )
Java: getMainThread() · also: get_main_thread

register_new_thread

ThreadContext register_new_thread ( RubyThread thread )
Java: registerNewThread(org.jruby.RubyThread thread)

set_main_thread

set_main_thread ( Thread thread, RubyThread ruby_thread )
Java: setMainThread(Thread thread, org.jruby.RubyThread rubyThread)

teardown

teardown ( )
Java: teardown()

unregister_current_thread

unregister_current_thread ( ThreadContext context )
Java: unregisterCurrentThread(org.jruby.runtime.ThreadContext context)

unregister_thread

unregister_thread ( RubyThread thread )
Java: unregisterThread(org.jruby.RubyThread thread)

Inherited

from ThreadLocal

get

T get ( )
Java: get()

remove

remove ( )
Java: remove()

set

set ( T arg0 )
Java: set(T arg0)