[intellij] remove fleet's ConcurrentHashMap usages from intellij code

GitOrigin-RevId: c4c207c4715a66fd2e70907c8a96fd851da27e5a
This commit is contained in:
Alexander Zolotov
2025-11-06 10:06:25 +00:00
committed by intellij-monorepo-bot
parent 56f9a6e5ba
commit 291f24fc94
12 changed files with 13 additions and 13 deletions
@@ -9,8 +9,8 @@ import com.intellij.platform.execution.dashboard.splitApi.RunDashboardLuxedConte
import com.intellij.platform.execution.dashboard.splitApi.RunDashboardServiceRpc
import com.intellij.platform.project.projectId
import com.intellij.platform.util.coroutines.childScope
import fleet.multiplatform.shims.ConcurrentHashMap
import kotlinx.coroutines.CoroutineScope
import java.util.concurrent.ConcurrentHashMap
@Service(Service.Level.PROJECT)
internal class FrontendRunDashboardLuxHolder(val project: Project, val coroutineScope: CoroutineScope) {
@@ -7,8 +7,8 @@ import com.intellij.platform.rpc.Id
import com.intellij.platform.rpc.UID
import com.intellij.util.AwaitCancellationAndInvoke
import com.intellij.util.awaitCancellationAndInvoke
import fleet.multiplatform.shims.ConcurrentHashMap
import kotlinx.coroutines.CoroutineScope
import java.util.concurrent.ConcurrentHashMap
import java.util.concurrent.atomic.AtomicInteger
@Service(Service.Level.APP)
@@ -10,7 +10,6 @@ import com.intellij.platform.debugger.impl.rpc.XBreakpointTypeId
import com.intellij.platform.project.projectId
import com.intellij.xdebugger.impl.breakpoints.XBreakpointTypeProxy
import com.intellij.xdebugger.impl.breakpoints.XLineBreakpointTypeProxy
import fleet.multiplatform.shims.ConcurrentHashMap
import fleet.rpc.client.durable
import kotlinx.coroutines.CompletableDeferred
import kotlinx.coroutines.CoroutineScope
@@ -19,6 +18,7 @@ import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.MutableSharedFlow
import kotlinx.coroutines.flow.collectLatest
import kotlinx.coroutines.launch
import java.util.concurrent.ConcurrentHashMap
@Service(Service.Level.PROJECT)
@@ -5,8 +5,8 @@ import com.intellij.openapi.project.Project
import com.intellij.platform.debugger.impl.frontend.frame.FrontendXStackFrame
import com.intellij.platform.debugger.impl.rpc.XStackFrameDto
import com.intellij.platform.debugger.impl.rpc.XStackFrameId
import fleet.multiplatform.shims.ConcurrentHashMap
import kotlinx.coroutines.CoroutineScope
import java.util.concurrent.ConcurrentHashMap
import kotlin.coroutines.AbstractCoroutineContextElement
import kotlin.coroutines.CoroutineContext
@@ -3,7 +3,6 @@ package com.intellij.platform.debugger.impl.frontend.tests
import com.intellij.openapi.util.Ref
import com.intellij.platform.debugger.impl.frontend.findOrAwaitElement
import fleet.multiplatform.shims.ConcurrentHashMap
import kotlinx.coroutines.channels.BufferOverflow
import kotlinx.coroutines.coroutineScope
import kotlinx.coroutines.flow.MutableSharedFlow
@@ -12,6 +11,7 @@ import kotlinx.coroutines.runBlocking
import kotlinx.coroutines.yield
import org.junit.jupiter.api.Assertions.assertEquals
import org.junit.jupiter.api.Test
import java.util.concurrent.ConcurrentHashMap
internal class FindOrAwaitElementTest {
@Test
@@ -6,10 +6,10 @@ import com.intellij.openapi.components.service
import com.intellij.openapi.extensions.ExtensionPointName
import com.intellij.openapi.project.Project
import com.intellij.xdebugger.frame.XDescriptor
import fleet.multiplatform.shims.ConcurrentHashMap
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.job
import org.jetbrains.annotations.ApiStatus
import java.util.concurrent.ConcurrentHashMap
/**
* Creates a plugin-specific state for a given [XDescriptor].
@@ -11,9 +11,9 @@ import com.intellij.util.AwaitCancellationAndInvoke
import com.intellij.util.awaitCancellationAndInvoke
import com.intellij.xdebugger.frame.XExecutionStack
import com.intellij.xdebugger.impl.XDebugSessionImpl
import fleet.multiplatform.shims.ConcurrentHashMap
import kotlinx.coroutines.CoroutineScope
import org.jetbrains.annotations.ApiStatus
import java.util.concurrent.ConcurrentHashMap
@ConsistentCopyVisibility
@ApiStatus.Internal
@@ -11,9 +11,9 @@ import com.intellij.util.AwaitCancellationAndInvoke
import com.intellij.util.awaitCancellationAndInvoke
import com.intellij.xdebugger.frame.XSuspendContext
import com.intellij.xdebugger.impl.XDebugSessionImpl
import fleet.multiplatform.shims.ConcurrentHashMap
import kotlinx.coroutines.CoroutineScope
import org.jetbrains.annotations.ApiStatus
import java.util.concurrent.ConcurrentHashMap
@ConsistentCopyVisibility
@ApiStatus.Internal
@@ -9,7 +9,7 @@ import com.intellij.openapi.project.Project
import com.intellij.openapi.vfs.VirtualFile
import com.intellij.vcs.log.VcsLogRangeFilter
import com.intellij.vcs.log.visible.filters.VcsLogFilterObject
import fleet.multiplatform.shims.ConcurrentHashMap
import java.util.concurrent.ConcurrentHashMap
@Service(Service.Level.PROJECT)
internal class GitCompareBranchesFilesManager(private val project: Project) : Disposable {
@@ -12,10 +12,10 @@ import com.intellij.openapi.vcs.VcsException
import com.intellij.openapi.vfs.VirtualFile
import com.intellij.util.concurrency.annotations.RequiresBackgroundThread
import com.intellij.util.messages.MessageBusConnection
import fleet.multiplatform.shims.ConcurrentHashMap
import git4idea.config.GitConfigUtil
import org.jetbrains.annotations.ApiStatus
import java.util.*
import java.util.concurrent.ConcurrentHashMap
import kotlin.jvm.optionals.getOrNull
@ApiStatus.Experimental
@@ -7,12 +7,12 @@ import com.intellij.openapi.components.Service
import com.intellij.openapi.components.service
import com.intellij.openapi.project.Project
import com.intellij.platform.vcs.impl.shared.rpc.RepositoryId
import fleet.multiplatform.shims.ConcurrentHashMap
import kotlinx.coroutines.CoroutineScope
import java.util.concurrent.ConcurrentHashMap
@Service(Service.Level.PROJECT)
internal class GitRepositoryIdCache(private val project: Project, cs: CoroutineScope) {
private val cache: MutableMap<RepositoryId, GitRepository?> = ConcurrentHashMap()
private val cache: MutableMap<RepositoryId, GitRepository> = ConcurrentHashMap()
init {
project.messageBus.connect(cs).subscribe<VcsRepositoryMappingListener>(
@@ -1,9 +1,9 @@
package com.intellij.terminal.backend
import com.intellij.openapi.project.Project
import fleet.multiplatform.shims.ConcurrentHashMap
import org.jetbrains.plugins.terminal.block.reworked.TerminalShellIntegrationEventsListener
import org.jetbrains.plugins.terminal.fus.ReworkedTerminalUsageCollector
import java.util.concurrent.ConcurrentHashMap
import kotlin.time.Duration.Companion.milliseconds
internal class TerminalShellIntegrationStatisticsListener(private val project: Project) : TerminalShellIntegrationEventsListener {