このコードでは、Collection.size（）を使用してカウンタを置き換えることはできますか？ここ

Question

はコードです：私たちは、単に数を取得するためにqueue.size()を使用できるよう

public class LogService { 
    private final BlockingQueue<String> queue; 
    private final LoggerThread loggerThread; 
    private final PrintWriter writer; 
    @GuardedBy("this") private boolean isShutdown; 
    @GuardedBy("this") private int reservations; // <-- counter 
    public void start() { loggerThread.start(); } 
    public void stop() { 
     synchronized (this) { isShutdown = true; } 
     loggerThread.interrupt(); 
    } 
    public void log(String msg) throws InterruptedException { 
     synchronized (this) { 
      if (isShutdown) 
       throw new IllegalStateException(...); 
      ++reservations; 
     } 
     queue.put(msg); 
    } 
    private class LoggerThread extends Thread { 
     public void run() { 
      try { 
       while (true) { 
        try { 
         synchronized (LogService.this) { 
          if (isShutdown && reservations == 0) 
           break; 
         } 
         String msg = queue.take(); 
         synchronized (LogService.this) { 
          --reservations; 
         } 
         writer.println(msg); 
        } catch (InterruptedException e) { /* retry */ } 
       } 
      } finally { 
       writer.close(); 
      } 
     } 
    } 
} 

それが本の練習でのJava並行処理からの抜粋だ、と私はそれについて考えているかもしれないカウンターreservationsは不要ですqueueの要素。

私は正しいですか？

Answer 1

いいえ、実際にはデッドロックが発生します。

sizeを並列に使用する場合は、putとtakeを同期させる必要があります。しかしtakeがブロックされ、put呼び出しと同じオブジェクトに対してブロックtake呼び出しが同期されるようになりました。 takeは、何かがputになるまで取ることができません。 putはロックを放棄するまでtakeまで置くことができません。それはデッドロックです。 「予約」を使用して

Answer 2

変数が良いドメイン設計がはるかに有意義なサイズよりもそれがされているためで、パフォーマンスの面で利用できる予約など

の総数のようなドメインの概念を表現するためにそれを使用することができます

ArrayBlockingQueue - 呼び出しサイズ関数は、サイズを読み取るためにロックを取得し、takeまたはput操作も遅くなるため遅くなります。

LinkedBlockingQueue - 呼び出しサイズはアトミック/揮発性読み取りであり、パフォーマンスコストがあります。