core/src/main/scala/spark/DaemonThreadFactory.scala


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

package spark

import java.util.concurrent.ThreadFactory

/**
 * A ThreadFactory that creates daemon threads
 */
private object DaemonThreadFactory extends ThreadFactory {
  override def newThread(r: Runnable): Thread = new DaemonThread(r)
}

private class DaemonThread(r: Runnable = null) extends Thread {
  override def run() {
    if (r != null) {
      r.run()
    }
  }
}