스칼라 : 슬리핑 웨이브

Question

스칼라에서 스레드를 알 수있는 방법 : 잠시만 기다려주십시오. 아니면 메시지를받을 때까지 기다려야합니까? 즉 최대 t 초 동안 휴면 상태가되지만, t가 끝나지 않고 특정 메시지를 수신하는 경우에 일어나야합니다.

Answer 1

또는 조건 변수를 사용할 수 있습니다.

val monitor = new AnyRef 
var messageReceived: Boolean = false 

// The waiting thread... 

def waitUntilMessageReceived(timeout: Int): Boolean = { 
    monitor synchronized { 
     // The time-out handling here is simplified for the purpose 
     // of exhibition. The "wait" may wake up spuriously for no 
     // apparent reason. So in practice, this would be more complicated, 
     // actually. 
     while (!messageReceived) monitor.wait(timeout * 1000L) 
     messageReceived 
    } 
} 

// The thread, which sends the message... 

def sendMessage: Unit = monitor synchronized { 
    messageReceived = true 
    monitor.notifyAll 
} 

Answer 2

주어진 시간 동안 잠자기 상태로 만들지 말고 Timeout() 메시지에서만 깨어나게 한 다음 "깨우기"를 원하면이 메시지를 중간에 보낼 수 있습니다.

Answer 3

체크 아웃 Await. Awaitable 개체가 있다면 필요한 것입니다.

Answer 4

대답은 메시지 이 무엇인지에 크게 의존한다. 액터 (이전 품종 또는 Akka variety)를 사용하는 경우 receive에서 시간 초과 값을 간단하게 지정할 수 있습니다. (이 메시지를 때까지 실제로 실행되지 반작용, 그래서 당신은 그것에 제한 시간을 배치 할 수 없습니다.)

// Old style 
receiveWithin(1000) { 
    case msg: Message => // whatever 
    case TIMEOUT =>  // Handle timeout 
} 

// Akka style 
context.setTimeoutReceive(1 second) 
def receive = { 
    case msg: Message => // whatever 
    case ReceiveTimeout => // handle timeout 
} 

그렇지 않으면, 정확하게는 "메시지"가 무엇을 의미합니까?

메시지를 보내는 쉬운 방법 중 하나는 이런 종류의 작업을 위해 만들어진 Java 동시 클래스를 사용하는 것입니다. 예를 들어, 메시지를 길게하는 java.util.concurrent.SynchronousQueue을 사용할 수 있으며, 수신기는 제한 시간 걸리는 poll 메서드를 호출 할 수 있습니다

// Common variable 
val q = new java.util.concurrent.SynchronousQueue[String] 

// Waiting thread 
val msg = q.poll(1000) 

// Sending thread will also block until receiver is ready to take it 
q.offer("salmon", 1000) 

ArrayBlockingQueue 원하는 경우 보낸 사람은 할 수 (이러한 상황에서 유용을 버퍼에 메시지를 패킹).