어떻게이 스레드를 안전하게 만들 수 있습니까?

Question

저는 클라이언트 (클라이언트 당 하나의 스레드)로부터 다양한 xml 메시지를 받고 메시지 유형에 따라 다른 기능으로 메시지를 라우팅하는 서버를 가지고 있습니다. 예 : 메시지의 첫 번째 요소에 'login'문자열이 포함되어 있으면이 메시지가 로그인 메시지임을 나타내며 메시지를 login() 함수로 라우팅합니다.

어쨌든 여러 클라이언트가 연결되어 있고 디스패처가 메시지 라우팅 중간에 스레드를 전환하면 상황이 엉망이되지 않도록이 메시지를 작성하려고합니다.

이

public void processMessagesFromClient(Client client) 
{ 
    Document message; 

    while (true) 
    { 
     try 
     { 
      message = client.inputStream.readObject(); 

      /* 
      * Determine the message type 
      */ 
      String messageType = getMessageType(message); 

      // Route the message depending on its type 
      switch (messageType) 
      { 
       case LOGIN: 
        userModel.handleLogin(); 
       ... 
       ... 
       ... 
       etc... 
      } 
     } catch(Exception e) {} 
    } 

그래서 어떻게이 스레드로부터 안전 할 수 있습니다 - 그래서 여기에 어떻게 메시지를 라우팅하고있다? 내가 어딘가에 있지만 어디 있는지 모르겠 동기화 성명을 넣어야 할 그림. (내 https://stackoverflow.com/a/416198/1088617

그리고 싱글이에 동기화 사용에 적합하지 않습니다 말한다 여기에 또 다른 포스트 - 또한 필자는 주제에 주위를 읽고 난 '이'동기 사용에 문제가 말한다이 게시물을 발견 위의 코드에서 클래스는 싱글 톤입니다.) - https://stackoverflow.com/a/416202/1088617

Answer 1

로컬 변수 만 사용 중이므로 클래스가 이미 스레드 안전성입니다. 스레드 안전은 코드 상태 인 (즉, 필드)에 액세스 할 때만 발생하며 코드에서는 수행하지 않습니다.

무슨 소리하는 직렬화 - 당신은 그 메시지 처리를 보장하기 위해 하나 개의 지점을 통해 모든 메시지 처리를 깔때기 할 것은 한 번에 하나씩 (시작하고 원자 완료)입니다. 이 솔루션은 간단

public void processMessagesFromClient(Client client) { Document Message; while (true) { processMessage(client); } } private static synchronized processMessage(Client client) { try { message = client.inputStream.readObject(); String messageType = getMessageType(message); // Route the message depending on its type switch (messageType) { case LOGIN: userModel.handleLogin(); ... etc... } } catch(Exception e) {} } 

가 FYI static synchronized 방법 로크로 클래스 오브젝트를 사용 : static synchronized 방법을 사용한다.이 코드는 코드가 단일 스레드처럼 동작하도록하여 질문이 원하는 것처럼 보입니다.

Answer 2

어떤 리소스가 특정 시간에 하나의 스레드로만 사용해야 하는지를 알아야합니다.

다음 메시지를 읽는 것이 보호되어야하는 경우가 있습니다.

synchronize (lock) { 
     message = client.inputStream.readObject(); 
} 

그러나, 코드 샘플은 정말 당신이 스레드 당 이러한 개체 중 하나가 제공 동시 액세스

Answer 3

보호에 필요한 사항이 표시되지 않습니다, 당신은 문제가 없습니다. 스레드 중 하나에 의해 수정 될 수있는 공유 객체 만 동기화하면됩니다. 이미 연결 당 하나의 스레드가있는 경우

public void processMessagesFromClient(Client client) {  
    while (true) { 
     processMessage(client); 
    } 
} 

private void processMessage(Client client) { 
    try { 
     Document message = client.inputStream.readObject(); 

     String messageType = getMessageType(message); 

     // Route the message depending on its type 
     switch (messageType) { 
      case LOGIN: 
       userModel.handleLogin(); 
      ... 
      etc... 
     } 
    } catch(Exception e) {} 
} 

Answer 4

, 당신은 동기화 할 수있는 유일한 방법은 이벤트 (userModel.handleLogin() 같은 즉, 기능)을 처리하는 기능은 다음과 같습니다.

Answer 5

가장 좋은 해결책은 ConcurrentQueue와 같은 스레드 안전 큐를 사용하고 단일 작업 스레드를 사용하여이 값을 선택하고 하나씩 작업을 실행하는 것입니다.

Answer 6

실제로 수신 메시지를 읽는 메시지 처리기 스레드가 있습니다. 그러면 처리기가 작업자 스레드로 넘겨 주어 시간이 오래 걸리는 메시지 처리가 수행됩니다. Java ThreadPoolExecutor를 사용하여이를 관리 할 수 ​​있습니다.

Answer 7

메서드 자체는 스레드로부터 안전합니다. 그러나이 클래스가 싱글 톤임을 알게되면 getInstance에 double checked locking을 사용하여 스레드 안전을 보장 할 수 있습니다. 또한 당신은 당신의 인스턴스가 새 스레드를 시작 static

 class Foo { 
      private static volatile Foo instance = null; 
      public static Foo getInstance() { 
       if (instance == null) 
       { 
        synchronized(this) 
        { 
         if (instance == null) 
          instance = new Foo(); 
        } 
       } 
       return instance ; 
      } 
     }