diff --git a/platform/util/src/com/intellij/util/concurrency/CancellationFutureTask.kt b/platform/util/src/com/intellij/util/concurrency/CancellationFutureTask.kt index d27c1297b352..6c3143f04f71 100644 --- a/platform/util/src/com/intellij/util/concurrency/CancellationFutureTask.kt +++ b/platform/util/src/com/intellij/util/concurrency/CancellationFutureTask.kt @@ -1,28 +1,21 @@ // Copyright 2000-2023 JetBrains s.r.o. and contributors. Use of this source code is governed by the Apache 2.0 license. -package com.intellij.util.concurrency; +package com.intellij.util.concurrency -import kotlinx.coroutines.Job; -import org.jetbrains.annotations.NotNull; - -import java.util.concurrent.Callable; -import java.util.concurrent.FutureTask; +import kotlinx.coroutines.Job +import java.util.concurrent.Callable +import java.util.concurrent.FutureTask /** * A FutureTask, which cancels the given job when it's cancelled. */ -final class CancellationFutureTask extends FutureTask { +internal class CancellationFutureTask( + private val job: Job, + callable: Callable, +) : FutureTask(callable) { - private final @NotNull Job myJob; - - CancellationFutureTask(@NotNull Job job, @NotNull Callable callable) { - super(callable); - myJob = job; - } - - @Override - public boolean cancel(boolean mayInterruptIfRunning) { - boolean result = super.cancel(mayInterruptIfRunning); - myJob.cancel(null); - return result; + override fun cancel(mayInterruptIfRunning: Boolean): Boolean { + val result = super.cancel(mayInterruptIfRunning) + job.cancel(null) + return result } }