How do you do atomic values in common code? atomic...

# multiplatform

[ribesg]

How do you do atomic values in common code? atomicfu seems broken, this test does not pass

@Test
    fun test() {
        val threadPool = newFixedThreadPoolContext(8, "TestDispatcher")
        val scope = CoroutineScope(threadPool)
        val atomic = atomic(0L)
        repeat(100_000) {
            scope.launch {
                atomic.incrementAndGet()
            }
        }
        assertEquals(100_000, atomic.value)
    }

Stately looks dead

[jw]

you aren't waiting for the jobs to complete

[ribesg]

Ah, tried to reduce a bigger use case into a test and failed miserably 😄

[ribesg]

This works so I probably have a similar issue somewhere in the real code

@Test
    fun test() = runBlocking {
        val threadPool = newFixedThreadPoolContext(8, "TestDispatcher")
        val scope = CoroutineScope(threadPool)
        val atomic = atomic(0L)
        val jobs = (1..100_000).map {
            scope.launch {
                atomic.incrementAndGet()
            }
        }
        jobs.joinAll()
        assertEquals(100_000, atomic.value)
    }