Add details for why the reference processing thread is started

Author: eregon

src/main/java/org/truffleruby/core/FinalizationService.java

@@ -111,7 +111,7 @@ public synchronized FinalizerReference addFinalizer(Object object, FinalizerRefe
 
         finalizerReference.addFinalizer(owner, action, root);
 
-        referenceProcessor.processReferenceQueue();
+        referenceProcessor.processReferenceQueue(owner);
         return finalizerReference;
     }
 

src/main/java/org/truffleruby/core/ReferenceProcessingService.java

@@ -113,7 +113,7 @@ public ReferenceProcessor(RubyContext context) {
             this.context = context;
         }
 
-        protected void processReferenceQueue() {
+        protected void processReferenceQueue(Class<?> owner) {
             if (context.getOptions().SINGLE_THREADED) {
 
                 drainReferenceQueue();
@@ -132,18 +132,19 @@ protected void processReferenceQueue() {
                  */
 
                 if (processingThread == null && !context.isPreInitializing() && context.isInitialized() && !context.isFinalizing()) {
-                    createProcessingThread();
+                    createProcessingThread(owner);
                 }
 
             }
         }
 
-        protected void createProcessingThread() {
+        protected void createProcessingThread(Class<?> owner) {
             final ThreadManager threadManager = context.getThreadManager();
             processingThread = threadManager.createBootThread(threadName());
             context.send(processingThread, "internal_thread_initialize");
+            final String sharingReason = "creating " + threadName() + " thread for " + owner.getSimpleName();
 
-            threadManager.initialize(processingThread, null, threadName(), () -> {
+            threadManager.initialize(processingThread, null, threadName(), sharingReason, () -> {
                 while (true) {
                     final ProcessingReference<?> reference = (ProcessingReference<?>) threadManager.runUntilResult(null, processingQueue::remove);
 

src/main/java/org/truffleruby/core/thread/ThreadManager.java

@@ -228,8 +228,8 @@ private void setupNativeThreadSupport(TruffleNFIPlatform nfi, NativeConfiguratio
         pthread_kill = nfi.getFunction("pthread_kill", "(" + pthread_t + ",sint32):sint32");
     }
 
-    public void initialize(DynamicObject rubyThread, Node currentNode, String info, Supplier<Object> task) {
-        startSharing(rubyThread, "creating Ruby Thread " + info);
+    public void initialize(DynamicObject rubyThread, Node currentNode, String info, String sharingReason, Supplier<Object> task) {
+        startSharing(rubyThread, sharingReason);
 
         Layouts.THREAD.setSourceLocation(rubyThread, info);
 

src/main/java/org/truffleruby/core/thread/ThreadNodes.java

@@ -279,13 +279,14 @@ public DynamicObject initialize(DynamicObject thread, DynamicObject arguments, D
             final SourceSection sourceSection = Layouts.PROC.getSharedMethodInfo(block).getSourceSection();
             final String info = getContext().fileLine(sourceSection);
             final Object[] args = boxedCopyNode.execute(Layouts.ARRAY.getStore(arguments), Layouts.ARRAY.getSize(arguments));
+            final String sharingReason = "creating Ruby Thread " + info;
 
             if (getContext().getOptions().SHARED_OBJECTS_ENABLED) {
-                getContext().getThreadManager().startSharing(thread, "creating Ruby Thread " + info);
+                getContext().getThreadManager().startSharing(thread, sharingReason);
                 SharedObjects.shareDeclarationFrame(getContext(), block);
             }
 
-            getContext().getThreadManager().initialize(thread, this, info,
+            getContext().getThreadManager().initialize(thread, this, info, sharingReason,
                     () -> ProcOperations.rootCall(block, args));
             return nil();
         }