Skip to content
This repository was archived by the owner on Dec 10, 2025. It is now read-only.

Commit ee4a63a

Browse files
committed
refactor(ServerQueueImpl): replace volatile suspended variable with AtomicBoolean for thread safety
1 parent 6090027 commit ee4a63a

File tree

1 file changed

+4
-2
lines changed
  • surf-cloud-standalone/src/main/kotlin/dev/slne/surf/cloud/standalone/server/queue

1 file changed

+4
-2
lines changed

surf-cloud-standalone/src/main/kotlin/dev/slne/surf/cloud/standalone/server/queue/ServerQueueImpl.kt

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,15 @@
11
package dev.slne.surf.cloud.standalone.server.queue
22

33
import dev.slne.surf.cloud.api.common.player.ConnectionResultEnum
4+
import dev.slne.surf.cloud.api.common.util.getValue
5+
import dev.slne.surf.cloud.api.common.util.setValue
46
import dev.slne.surf.cloud.api.server.queue.QueueEntry
57
import dev.slne.surf.cloud.api.server.queue.ServerQueue
68
import dev.slne.surf.cloud.standalone.server.queue.repo.QueueRepository
79
import dev.slne.surf.cloud.standalone.server.serverManagerImpl
810
import net.kyori.adventure.text.Component
911
import java.util.*
12+
import java.util.concurrent.atomic.AtomicBoolean
1013

1114
class ServerQueueImpl(
1215
override val serverUid: Long,
@@ -16,8 +19,7 @@ class ServerQueueImpl(
1619

1720
val groupQueue get() = queues.getGroup(latestGroup)
1821

19-
@Volatile
20-
override var suspended: Boolean = false
22+
override var suspended: Boolean by AtomicBoolean()
2123

2224
override val online get() = serverManagerImpl.getServerByIdUnsafe(serverUid) != null
2325

0 commit comments

Comments
 (0)