terribleplan/mangadex_at_home
1
0
Fork 0
forked from gitlab-com-mangadex-pub/mangadex_at_home
Code Issues Pull requests Releases Wiki Activity

Make Netty naive-multithreaded too

Browse source 
Hopefully we can replace this that intelligently scales to a user
setting next time...
This commit is contained in:
Amos Ng 2020-06-12 00:55:47 +08:00
parent 5dbe29c8e9
commit da47b86d97
No known key found for this signature in database
GPG key ID: 89086414F634D123
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/main/kotlin/mdnet/base/Application.kt
View file

@ -39,7 +39,7 @@ import javax.crypto.CipherOutputStream
import javax.crypto.spec.SecretKeySpec
private val LOGGER = LoggerFactory.getLogger("Application")
private val THREADS_TO_ALLOCATE = Runtime.getRuntime().availableProcessors() * 30 / 2
private val THREADS_TO_ALLOCATE = Runtime.getRuntime().availableProcessors() * 30
fun getServer(cache: DiskLruCache, serverSettings: ServerSettings, clientSettings: ClientSettings, statistics: AtomicReference<Statistics>): Http4kServer {
val executor = Executors.newCachedThreadPool()

4
src/main/kotlin/mdnet/base/Netty.kt
View file

@ -38,8 +38,8 @@ private val LOGGER = LoggerFactory.getLogger("Application")
class Netty(private val tls: ServerSettings.TlsCert, private val clientSettings: ClientSettings, private val stats: AtomicReference<Statistics>) : ServerConfig {
override fun toServer(httpHandler: HttpHandler): Http4kServer = object : Http4kServer {
private val masterGroup = NioEventLoopGroup()
private val workerGroup = NioEventLoopGroup()
private val masterGroup = NioEventLoopGroup(Runtime.getRuntime().availableProcessors() * 30 / 2)
private val workerGroup = NioEventLoopGroup(Runtime.getRuntime().availableProcessors() * 30 / 2)
private lateinit var closeFuture: ChannelFuture
private lateinit var address: InetSocketAddress