静的クラスでのファイル出力の同期

Question

2つの異なるテキストファイルに書き込む必要があるスレッドがいくつかあります。これまでのところ、私はこのコードを持っている：

public class Logger { 

    public static void printToGameLog(String value){ 
     Writer writer = null; 
     try { 
      writer = new BufferedWriter(new OutputStreamWriter(
       new FileOutputStream("GameLog.txt", true), "utf-8")); 
      synchronized(writer){ 
       writer.write(outputString + "\r\n"); 
      } 
     } catch (IOException ex){ 
      System.out.println("cannot create log file"); 
     } 
    } 


    public static void printToServerLog(String value){ 
     Writer writer = null; 
     try { 
      writer = new BufferedWriter(new OutputStreamWriter(
       new FileOutputStream("serverLog.txt", true), "utf-8")); 
      synchronized(writer){ 
       writer.write(outputString + "\r\n"); 
      } 
     } catch (IOException ex){ 
      System.out.println("cannot create log file"); 
     } 
    } 
} 

が、これは1個以下のスレッドが同時に同じファイルに書き込んでいる確保の許容可能な方法は何ですか？

スレッドがこれらのメソッドのいずれかを呼び出してsyncブロックに入ると、別のスレッドが来て同じメソッドを実行しようとするとどうなりますか？ローカル変数writerを使用しようとすると、他のスレッドによってロックされた同じオブジェクトが取得され、ブロックされますか？私はそれが単なる独自の別の変数を作成すると思っていたでしょう。これは、代わりに静的なクラス変数を作者にしなければならないということでしょうか？あなたのコード内でnullポインタ例外だ

Answer 1

別々のログファイルがあるので、なぜクラスレベルの同期が必要かわかりません。不必要なボトルネックのようです。私は、別々の方法で別々のファイルにヒットするので、別々の方法ごとに同期を提供しています。

public class Logger 
{ 
    private static final Object GAME_LOG_LOCK = new Object(); 
    private static final Object SERVER_LOG_LOCK = new Object(); 

    public static void printToGameLog(String value){ 
     synchronized (GAME_LOG_LOCK) { 
      Writer writer = null; 
      try { 
       writer = new BufferedWriter(new OutputStreamWriter(
        new FileOutputStream("GameLog.txt", true), "utf-8")); 
       writer.write(outputString + "\r\n"); 
      } catch (IOException ex){ 
       System.out.println("cannot create log file"); 
      } 
     } 
    } 

    public static void printToServerLog(String value){ 
     synchronized (SERVER_LOG_LOCK) { 
      Writer writer = null; 
      try { 
       writer = new BufferedWriter(new OutputStreamWriter(
        new FileOutputStream("serverLog.txt", true), "utf-8")); 
       writer.write(outputString + "\r\n"); 
      } catch (IOException ex){ 
        System.out.println("cannot create log file"); 
      } 
     } 
    } 
} 

Answer 2

、静的メソッドに

synchronized(Logger.class){ 

または別の代替を同期ブロックを使用して、この方法を試してみてください。この

public static synchronized void printToGameLog(String value){ 

などの同期全体の方法を、設定することです

と

public static synchronized void printToServerLog(String value){ 

私はあなたが同期を必要とすることを確信していませんここでは、複数のスレッドから読み書きされている状態がある場合にのみ、同期が必要です。

Answer 3

これは別の問題です。ログファイルを書き込むために単一のスレッドを使用し、このスレッドのみがファイルにアクセスします。ログを取らなければならないスレッドは、BlockingQueueに対して書き込みます。

public class ThreadedLog { 

    //This is some code to test the logger 
    public static void main(String[] args) throws UnsupportedEncodingException, FileNotFoundException { 

     ThreadedLog log = new ThreadedLog("/tmp/test.txt"); 
     // Start 100 thread that write against the log 
     for (int i = 0; i < 100; i++) { 
      new Thread(new TestLogger(log)).start(); 
     } 
    } 

    private static class TestLogger implements Runnable { 

     private ThreadedLog log; 

     public TestLogger(ThreadedLog log) { 
      this.log = log; 
     } 

     @Override 
     public void run() { 
      for (int i = 0; i < 5000; i++) { 
       try { 
        log.log("This is entry " + i + " from thread " + Thread.currentThread().getId()); 
       } catch (InterruptedException ex) { 
       } 
      } 
      System.out.println(Thread.currentThread().getId() + " is done"); 
     } 
    } 
    //________________________________________________________________________________________________ 
    /* 
    * This is the code for the actual logger 
    * 
    */ 
    private final BlockingQueue<String> queue = new ArrayBlockingQueue<>(10000); 
    private String fileName; 
    private Thread thread; 
    private Writer writer; 

    public ThreadedLog(String fileName) throws UnsupportedEncodingException, FileNotFoundException { 
     this.fileName = fileName; 
     thread = new Thread(new LoggingThread()); 
     writer = new BufferedWriter(new OutputStreamWriter(
      new FileOutputStream(fileName, true), "utf-8")); 
     thread.start(); 
    } 

    private class LoggingThread implements Runnable { 

     @Override 
     public void run() { 

      try { 
       for (;;) { 
        ThreadedLog.this.writer.write(queue.take() + "\r\n"); 
        ThreadedLog.this.writer.flush(); 
       } 
      } catch (InterruptedException | IOException e) { 
       e.printStackTrace(); 
       try { 
        ThreadedLog.this.writer.close(); 
       } catch (Exception ex) { 
       } 
      } 
     } 
    } 

    public void log(String string) throws InterruptedException { 
     queue.put(string); 
    } 
}