|
@@ -18,6 +18,8 @@
|
|
|
|
|
|
package org.apache.hadoop.util;
|
|
|
|
|
|
+import java.util.concurrent.ThreadFactory;
|
|
|
+
|
|
|
import org.apache.hadoop.classification.InterfaceAudience;
|
|
|
import org.apache.hadoop.classification.InterfaceStability;
|
|
|
|
|
@@ -30,6 +32,19 @@ public class Daemon extends Thread {
|
|
|
setDaemon(true); // always a daemon
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * Provide a factory for named daemon threads,
|
|
|
+ * for use in ExecutorServices constructors
|
|
|
+ */
|
|
|
+ public static class DaemonFactory extends Daemon implements ThreadFactory {
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Thread newThread(Runnable runnable) {
|
|
|
+ return new Daemon(runnable);
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
Runnable runnable = null;
|
|
|
/** Construct a daemon thread. */
|
|
|
public Daemon() {
|