배우

Question

내부 Thread.sleep를 호출하면 기본적으로 내가이 (간체)과 같은 기능 재시도있다. 내가 들었는데, 그것은 배우 내부 Thread.sleep(123) 전화를 허용 아니다 : 그래서 만약

class MyActor extends Actor { 
    //...... 
    def someFunc = { 
    SomeObject.retry(5)(someRequestToServer) // ops, SomeObject.retry uses Thread.sleep! 
    } 

} 

: 분명히

class MyActor extends Actor { 
    //...... 
    def someFunc = { 
    Thread.sleep(456) // it's not acceptable in an actor, there is another way to do it 
    } 

} 

, 나는 클라이언트가 배우 내부 SomeObject.retry을 사용할지 여부를 모른다 방금 추가 :

res match { 
     case Some(x) => Some(x) 
     case None => 
     if (n > 1) 
      //make it sleep for a little while 
      Thread.sleep(123) // ops, what if it's being called inside an actor by a client?! 
      retry(n - 1)(fn) 
     else None 
    } 
    } 

그것은 합리적이지 않습니까? 그렇지 않다면 어떻게해야합니까?

Answer 1

예, Thread.sleep을 호출하는 것은 나쁜 생각입니다. 시스템에서 스레드는 일반적으로 액터간에 공유되는 제한된 리소스입니다. 당신은 잠을 자면서 다른 액터로부터 스레드를 쫓아 내기를 원하지 않습니다.

Scheduler (docs 참조)을 사용하면 배우가 나중에 다시 시도 할 메시지를 보내도록 할 수 있습니다. SomeObject.attempt은 어디에서 이렇게하려면, 당신은 당신이 배우의 SomeObject.try 외부를 사용한다면 SomeObject에서 다음 Actor

class MyActor extends Actor { 

    import context.system.dispatcher 

    def receive = { 
    case DoIt(retries) if retries > 0 => 
     SomeObject.attempt(someRequestToServer) match { 
     case Some(x) => ... 
     case None => 
      context.system.scheduler.scheduleOnce(5.seconds, self, DoIt(retries - 1)) 
     } 
    } 

} 

에 시스템

def attempt(retries: Int) = { 
    SomeObject.attempt(someRequestToServer) match { 
    case Some(x) => ... 
    case None if retries > 0 => { 
     Thread.sleep(123) 
     attempt(retries - 1) 
    } 
    } 
} 

을 재시도 코드를 이동해야합니다 :

를

object SomeObject { 
    def attempt[T](fn: => T): Option[T] = 
    try { 
     Some(fn) 
    } catch { 
     case _: Exception => None 
    } 
}