8345432: (ch, fs) Replace anonymous Thread with InnocuousThread

Reviewed-by: alanb

Author: Brian Burkhalter

src/java.base/share/classes/sun/nio/ch/ThreadPool.java

@@ -70,7 +70,7 @@ int poolSize() {
 
     static ThreadFactory defaultThreadFactory() {
         return (Runnable r) -> {
-            Thread t = new Thread(r);
+            Thread t = InnocuousThread.newThread(r);
             t.setDaemon(true);
             return t;
         };

src/java.base/share/classes/sun/nio/fs/AbstractPoller.java

@@ -25,9 +25,10 @@
 
 package sun.nio.fs;
 
-import java.nio.file.*;
 import java.io.IOException;
+import java.nio.file.*;
 import java.util.*;
+import jdk.internal.misc.InnocuousThread;
 
 /**
  * Base implementation of background poller thread used in watch service
@@ -53,11 +54,7 @@ protected AbstractPoller() {
      * Starts the poller thread
      */
     public void start() {
-        Thread thr = new Thread(null,
-                                this,
-                                "FileSystemWatchService",
-                                0,
-                                false);
+        Thread thr = InnocuousThread.newThread("FileSystemWatchService", this);
         thr.setDaemon(true);
         thr.start();
     }

src/java.base/share/classes/sun/nio/fs/Cancellable.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2008, 2009, Oracle and/or its affiliates. All rights reserved.
+ * Copyright (c) 2008, 2024, Oracle and/or its affiliates. All rights reserved.
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
  *
  * This code is free software; you can redistribute it and/or modify it
@@ -25,14 +25,15 @@
 
 package sun.nio.fs;
 
-import jdk.internal.misc.Unsafe;
 import java.util.concurrent.ExecutionException;
+import jdk.internal.misc.InnocuousThread;
+import jdk.internal.misc.Unsafe;
 
 /**
  * Base implementation of a task (typically native) that polls a memory location
  * during execution so that it may be aborted/cancelled before completion. The
- * task is executed by invoking the {@link runInterruptibly} method defined
- * here and cancelled by invoking Thread.interrupt.
+ * task is executed by invoking the {@linkplain #runInterruptibly} method
+ * defined here and cancelled by invoking Thread.interrupt.
  */
 
 abstract class Cancellable implements Runnable {
@@ -117,7 +118,7 @@ public final void run() {
      * thread by writing into the memory location that it polls cooperatively.
      */
     static void runInterruptibly(Cancellable task) throws ExecutionException {
-        Thread t = new Thread(null, task, "NIO-Task", 0, false);
+        Thread t = InnocuousThread.newThread("CancellableOp", task);
         t.start();
         boolean cancelledByInterrupt = false;
         while (t.isAlive()) {

src/java.base/share/classes/sun/nio/fs/PollingWatchService.java

@@ -47,6 +47,7 @@
 import java.util.concurrent.ScheduledFuture;
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.TimeUnit;
+import jdk.internal.misc.InnocuousThread;
 import static java.nio.file.LinkOption.NOFOLLOW_LINKS;
 
 /**
@@ -73,7 +74,7 @@ class PollingWatchService
             .newSingleThreadScheduledExecutor(new ThreadFactory() {
                  @Override
                  public Thread newThread(Runnable r) {
-                     Thread t = new Thread(null, r, "FileSystemWatcher", 0, false);
+                     Thread t = InnocuousThread.newThread("FileSystemWatcher", r);
                      t.setDaemon(true);
                      return t;
                  }});

src/java.base/windows/classes/sun/nio/ch/PipeImpl.java

@@ -78,7 +78,7 @@ public void init() throws IOException {
             connector.run();
             if (ioe instanceof ClosedByInterruptException) {
                 ioe = null;
-                Thread connThread = new Thread(connector) {
+                Thread connThread = new Thread(connector, "LoopbackConnector") {
                     @Override
                     public void interrupt() {}
                 };