기아 스레드

Question

내가 기아 문제를 방지 할 수있는 방법은 수면을 쓰는 시뮬레이션 방법으로 인한 것입니까? 스레드를 오랫동안 잠자기 상태로두면 잠시 동안 잠자기 한 것보다 절대로 쓸 수 없습니다.

이 프로그램은 my_file 클래스의 쓰기 메서드에 지속적으로 액세스하는 많은 스레드로 구성되어 있습니다. 모든 스레드가 공유하지만 한 번에 하나의 스레드 만 파일에 쓸 수 있습니다.

public class My_File { 

    private boolean writing = false; 

    public synchronized void write() { 
    String name = Thread.currentThread().getName(); 
    System.out.println(name +" writing "); 
    try{ 
     Thread.sleep((int)(Math.random()*3000)); 
    } catch(InterruptedException e){ 
     e.printStackTrace(); 
    } 
    System.out.println(name +" writing end "); 
    } 
} 

나는이 문제를 가지고, 나는 많은 스레드에 의해 공유 파일을 많이 가지고 있지만, 아무것도하지 않고 모든 스레드가 경우에 파일에 기록하려고 기입 방법 수면에 의해 시뮬레이션, 난 몰라 이 상황에서 기아를 막을 수있는 방법은 무엇입니까?

Answer 1

일정한 처리량을 보장하려면 공정한 재진입 성이 필요합니다. 귀하의 경우는 버그 설명에서

"단순"동기화 "잠금은 대기중인 스레드에 의해 잠금을 얻는 순서를 보장하지 않으므로"마지막으로 입력 한 "스레드가 잠금을 얻는 경우, Logback 버그 268과 매우 유사합니다. "처음 입력"동안 스레드 ... 아주 긴 시간 동안 "

및

"를 기다릴 수 나는 java.util.concurrent.locks.ReentrantLock는 "공정"모드에서 작업으로이 자물쇠를 교체하려고 상황이 크게 좋아졌습니다! "

코드 변경 사항은 github commit에 표시됩니다. 이 패턴에

class MyFileUnfair { 

    private final Object writeLock = new Object(); 

    public void write(byte[] data) { 

     synchronized(writeLock) { 
      writeToFile(data); 
     } 
    } 

    private void writeToFile(byte[] data) { 
     // write to file 
    } 
} 

: 의사 코드에서이 패턴을 변경 그것이 현재의 형태로 해석 할 수없는 그대로

class MyFileFair { 

    private final ReentrantLock writeLock = new ReentrantLock(true); 

    public void write(byte[] data) { 

     writeLock.lock(); 
     try { 
      writeToFile(data); 
     } finally { 
      writeLock.unlock(); 
     } 
    } 

    private void writeToFile(byte[] data) { 
     // write to file 
    } 
}