dorkbox
/
Network
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Updated to 100 concurrent connections (on 50 separate threads)

This commit is contained in:
Robinson 2023-11-13 18:44:59 +01:00
parent bae5b41d1c
commit 35020adac9
No known key found for this signature in database
GPG Key ID: 8E7DB78588BD6F5C
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
test/dorkboxTest/network/MultiClientTest.kt
View File

@ -23,7 +23,8 @@ import dorkbox.network.connection.Connection
import dorkbox.util.NamedThreadFactory import dorkbox.util.NamedThreadFactory
import io.aeron.driver.ThreadingMode import io.aeron.driver.ThreadingMode
import kotlinx.atomicfu.atomic import kotlinx.atomicfu.atomic
import kotlinx.coroutines.* import kotlinx.coroutines.DelicateCoroutinesApi
import kotlinx.coroutines.ExperimentalCoroutinesApi
import org.junit.Assert import org.junit.Assert
import org.junit.Test import org.junit.Test
import java.text.SimpleDateFormat import java.text.SimpleDateFormat
@ -32,7 +33,7 @@ import java.util.concurrent.*
@Suppress("UNUSED_ANONYMOUS_PARAMETER") @Suppress("UNUSED_ANONYMOUS_PARAMETER")
class MultiClientTest : BaseTest() { class MultiClientTest : BaseTest() {
private val totalCount = 40 private val totalCount = 100
private val clientConnectCount = atomic(0) private val clientConnectCount = atomic(0)
private val serverConnectCount = 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! // 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) NamedThreadFactory("Unit Test Client", Configuration.networkThreadGroup, true)
) )