整改2
This commit is contained in:
parent
c777831fde
commit
4d87d0d84f
@ -6,6 +6,7 @@ import java.net.ServerSocket
|
||||
import java.net.Socket
|
||||
import java.util.*
|
||||
import java.util.concurrent.CopyOnWriteArrayList
|
||||
import kotlin.system.measureTimeMillis
|
||||
|
||||
var clientAudios: MutableList<ClientAudio> = CopyOnWriteArrayList()
|
||||
|
||||
@ -24,11 +25,14 @@ fun main() = runBlocking {
|
||||
|
||||
for (client in clientAudios) {
|
||||
launch(Dispatchers.IO) {
|
||||
for (audio in clientAudios) {
|
||||
if (audio != client)
|
||||
audio.mix(client.sample)
|
||||
val t = measureTimeMillis {
|
||||
for (audio in clientAudios) {
|
||||
if (audio != client)
|
||||
audio.mix(client.sample)
|
||||
}
|
||||
client.send()
|
||||
}
|
||||
client.send()
|
||||
println("server send time: $t")
|
||||
}
|
||||
}
|
||||
}
|
||||
|
Loading…
x
Reference in New Issue
Block a user