java.util.concurrent

java 5에서 추가된 패키지로, 동기화가 필요한 상황에서 사용할 수 있는 다양한 유틸리티 클래스들을 제공한다.

java.util.concurrent.locks

locks 패키지엔 상호 배제를 위한 Lock API가 정의되어 있다. synchronized를 더욱 유연하고 정교하게 처리하기 위해 사용하기 위해 만들어 진것이며, 대체하는 목적을 가지진 않는다.

Interface

• Lock: 공유 자우너에 한번에 한 쓰레드만 read, write를 수행 가능하도록 한다.
• ReadWriteLock: Lock에서 한단계 발전된 매커니즘을 제공하는 인터페이스이다. 공유자원에 여러개의 쓰레드가 read를 수행할 수 있지만, write는 한번에 한 쓰레드만 수행 가능하다.
• Condition: Object 클래스의 monitor method인 wait, nofity, notifyAll 메소드를 대체한다, wait → await notify → signal notifyAll → signalAll

Impl

• ReentrantLock: Lock 의 구현체. 임계영역의 시작 지점과 종료 지점을 직접 명시할 수 있게 해준다.
• ReentrantReadWriteLock: ReadWriteLock의 구현체

간단 예제

class SharedData {
    private var value: Int =0

    fun increase() {
        value += 1
    }

    fun print() = println(value)
}

class Test (private val sharedData: SharedData): Runnable {
    override fun run() {
        for (i in 1..100) sharedData.increase()

        sharedData.print()
    }
}

fun main() {
    val sharedData = SharedData()

    for (i in 1..10) {

        Thread(Test(sharedData)).start()
    }
}

락을 사용하지 않으면 여러 쓰레드에서 동시 접근하기에 번호가 뒤죽박죽이다.