히카리 풀을 사용하게 되면 housekeeper란 놈이 기본으로 30초마다 풀 상태를 debug모드로 찍고있는데

커스터마이징이 잘 안되서 별도로 찍기로 함

@SpringBootApplication
@EnableScheduling
class ApiApplication(
        val dataSource: DataSource) {

    @Scheduled(fixedDelay = 10000)
    fun hikariPoolMonitor() {
        (DirectFieldAccessor(dataSource).getPropertyValue("pool") as HikariPool?)?.let { hikariPool ->
            logger().info("Pool stats (total=${hikariPool.totalConnections}, active=${hikariPool.activeConnections}, idle=${hikariPool.idleConnections}, waiting=${hikariPool.threadsAwaitingConnection})")
        }
    }
}

2020-04-28 11:22:58,868 INFO  [scheduling-1] [||] [n.d.api.ApiApplication:23] : Pool stats (total=50, active=0, idle=50, waiting=0)
2020-04-28 11:23:08,868 INFO  [scheduling-1] [||] [n.d.api.ApiApplication:23] : Pool stats (total=50, active=0, idle=50, waiting=0)
2020-04-28 11:23:18,869 INFO  [scheduling-1] [||] [n.d.api.ApiApplication:23] : Pool stats (total=50, active=0, idle=50, waiting=0)

다음과 같이 여러개의 작업을 동시에 처리할때 작업1,2가 메인작업과 별개의 작업일때

비동기(@Async)로 던져놓고 메인 작업만 완료 후 응답을 주기도 합니다.

(응답시간 0.5초, 작업1,2의 결과 받을 수 없음)

메인작업 : 0.5초

작업1 : 1초

작업2 : 2초

하지만 3가지 작업의 결과가 모두 필요할 경우 동기 처리를 하면 3.5초가 걸리지만

작업1, 2를 비동기로 처리하면 일찍 처리가 끝난 작업은 모든 작업이 완료될때까지 대기 후 응답을 줍니다.

(응답시간 2초, 3개의 작업 결과 확인 가능)

Kotlin

@RestController
@EnableAsync
class ThreadTest(
        val taskService: TaskService,
        val mainService: MainService
) {
    @GetMapping("task")
    fun testMapping(): String {
        val start = System.currentTimeMillis()

        val task1 = taskService.task1()
        val task2 = taskService.task2()
        val main = mainService.task()

        return "main[$main], task1[${task1.get()}], task2[${task2.get()}], total[${System.currentTimeMillis()-start}]"
    }
}

@Service
class MainService {
    fun task(): Long {
        val start = System.currentTimeMillis()
        Thread.sleep(500)
        return (System.currentTimeMillis()-start)
    }
}

@Service
class TaskService {
    @Async
    fun task1(): CompletableFuture<Long> {
        val start = System.currentTimeMillis()
        Thread.sleep(1000)
        return CompletableFuture.completedFuture(System.currentTimeMillis()-start)
    }

    @Async
    fun task2(): CompletableFuture<Long> {
        val start = System.currentTimeMillis()
        Thread.sleep(2000)
        return CompletableFuture.completedFuture(System.currentTimeMillis()-start)
    }
}

테스트1

http://localhost:8080/task

main[502], task1[1001], task2[2001], total[2007]

메인 작업은 처리 완료 후 비동기 작업들이 완료될때까지 대기 후 응답을 주고 있습니다.

테스트2

반대로 동기로 처리하는 메인작업이 오래걸릴 경우도 테스트 해보겠습니다.

(MainService의 작업시간을 3초로 늘려주세요)

메인작업 : 3초

작업1 : 1초

작업2 : 2초

http://localhost:8080/task

main[3001], task1[1001], task2[2001], total[3004]

당연히 메인작업이 처리되는동안 1,2번 작업은 비동기로 작업을 완료하고 응답을 같이 주고 있습니다.

* 동시에 여러 곳을 연동해서 결과를 취합한다거나

  자원이 남아 별도의 스레드에서 처리하고자 할 때 사용하시면 됩니다.

코틀린에서 숫자 변환시에 자주 쓰이는 함수입니다.

다른 용도로 숫자인지 아닌지를 판단할때도 자주 쓰는데 주의할 점이 있습니다

fun main(args:Array<String>)
{
    "1234".run {
        println(this.toIntOrNull() ?: "$this is not number")
   }
    "349505749735".run {
        println(this.toIntOrNull() ?: "$this is not number")
        println(this.toBigIntegerOrNull() ?: "$this is not number")
    }
}

//1234
//349505749735 is not number
//349505749735

위 예제를 보시면 문자열이 숫자인지 아닌지 판단하기 위해 toIntOrNull을 사용하였지만

중간에 숫자가 아니라고 나오는 경우가 발생합니다.

이미 눈치채셨겠지만 숫자가 너무 커서 toInt를 하지 못한 경우입니다.

toBigIntegerOrNull로 대체해서 해결되었지만 무심코 쓰다가 실수할 수 있는 부분이니 신경 써주면 좋습니다