동시성 테스트

numberOfThreads.kt

    @Test
    fun tokenRepositoyTest(){

        val tokenRepository:TokenRepository = MemoryTokenRepositoryImpl()
        val numberOfThreads = 1000
        val service = Executors.newFixedThreadPool(10)
        val latch = CountDownLatch(numberOfThreads)

        for ( index in 1..numberOfThreads){
            service.submit {
                tokenRepository.save(index.toString(), "${index.toString()}" )
                latch.countDown()
            }
        }

        latch.await()

        val results1 = tokenRepository.findAll().map { it.toInt() }.sorted()

        Assertions.assertThat(results1.size).isEqualTo(numberOfThreads);

        log.info { "size1: ${results1.size}" }


        //tokenRepository.clearStore()

        //Thread.sleep(5000)


        for (s in results1) {
            val remove = tokenRepository.remove(s.toString())
            if (s == 500) {
                break
            }
            //log.info { "remove: $remove" }
        }


        val results2 = tokenRepository.findAll().map { it.toInt() }.sorted()

        log.info { "size2: ${results2.size}" }

    }