diff options
Diffstat (limited to 'core/src/main/scala/org/apache/spark/util/UninterruptibleThread.scala')
-rw-r--r-- | core/src/main/scala/org/apache/spark/util/UninterruptibleThread.scala | 7 |
1 files changed, 0 insertions, 7 deletions
diff --git a/core/src/main/scala/org/apache/spark/util/UninterruptibleThread.scala b/core/src/main/scala/org/apache/spark/util/UninterruptibleThread.scala index 4dcf95177a..f0b68f0cb7 100644 --- a/core/src/main/scala/org/apache/spark/util/UninterruptibleThread.scala +++ b/core/src/main/scala/org/apache/spark/util/UninterruptibleThread.scala @@ -90,13 +90,6 @@ private[spark] class UninterruptibleThread(name: String) extends Thread(name) { } /** - * Tests whether `interrupt()` has been called. - */ - override def isInterrupted: Boolean = { - super.isInterrupted || uninterruptibleLock.synchronized { shouldInterruptThread } - } - - /** * Interrupt `this` thread if possible. If `this` is in the uninterruptible status, it won't be * interrupted until it enters into the interruptible status. */ |