From 35020adac99fb7ebc59c576cfc0c4df894391a1d Mon Sep 17 00:00:00 2001 From: Robinson Date: Mon, 13 Nov 2023 18:44:59 +0100 Subject: [PATCH] Updated to 100 concurrent connections (on 50 separate threads) --- test/dorkboxTest/network/MultiClientTest.kt | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/test/dorkboxTest/network/MultiClientTest.kt b/test/dorkboxTest/network/MultiClientTest.kt index eb7a9066..506d7c1a 100644 --- a/test/dorkboxTest/network/MultiClientTest.kt +++ b/test/dorkboxTest/network/MultiClientTest.kt @@ -23,7 +23,8 @@ import dorkbox.network.connection.Connection import dorkbox.util.NamedThreadFactory import io.aeron.driver.ThreadingMode import kotlinx.atomicfu.atomic -import kotlinx.coroutines.* +import kotlinx.coroutines.DelicateCoroutinesApi +import kotlinx.coroutines.ExperimentalCoroutinesApi import org.junit.Assert import org.junit.Test import java.text.SimpleDateFormat @@ -32,7 +33,7 @@ import java.util.concurrent.* @Suppress("UNUSED_ANONYMOUS_PARAMETER") class MultiClientTest : BaseTest() { - private val totalCount = 40 + private val totalCount = 100 private val clientConnectCount = atomic(0) private val serverConnectCount = atomic(0) @@ -97,7 +98,7 @@ class MultiClientTest : BaseTest() { } // if we are on the same JVM, the defaultScope for coroutines is SHARED, and limited! - val differentThreadLaunchers = Executors.newFixedThreadPool(8, + val differentThreadLaunchers = Executors.newFixedThreadPool(totalCount/2, NamedThreadFactory("Unit Test Client", Configuration.networkThreadGroup, true) )