aboutsummaryrefslogtreecommitdiff
path: root/core/src/main/scala/org/apache/spark/util/UninterruptibleThread.scala
diff options
context:
space:
mode:
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.scala7
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.
*/