Application.kt

@file:Suppress("KDocMissingDocumentation")

import io.ktor.client.HttpClient
import io.ktor.client.engine.apache.Apache
import io.ktor.client.request.get
import kotlinx.coroutines.Runnable
import kotlinx.coroutines.delay
import kotlinx.coroutines.runBlocking
import java.util.concurrent.ThreadFactory
import java.util.concurrent.TimeUnit
import java.util.concurrent.atomic.AtomicInteger

class NamedThreadFactory private constructor(
    private val name: (Int) -> String, private val daemon: Boolean
) : ThreadFactory {
    private val index = AtomicInteger()

    constructor(prefix: String, daemon: Boolean = false) : this({ "$prefix$it" }, daemon)

    override fun newThread(r: Runnable) = Thread(r, name(index.incrementAndGet())).apply { isDaemon = daemon }
}

fun main() = runBlocking {
    val url =
        "https://github.com/jvm-profiling-tools/async-profiler/releases/download/v1.5/async-profiler-1.5-linux-x64.tar.gz"

    val httpClient = HttpClient(Apache) {
        engine {
            customizeClient {
                setThreadFactory(NamedThreadFactory("Apache-http-client-apm-client-", daemon = true))
            }
        }
    }

    val archive = httpClient.get<ByteArray>(url)

    println("got bytes: ${archive.size}, client: $httpClient")

    delay(TimeUnit.HOURS.toMillis(10))

    println("after 10 hours: got bytes: ${archive.size}, client: ${httpClient}")
}