5

AbstractQueuedSynchronizerを使用する単純なクラスを作成しました。「ゲート」を表すクラスを作成しました。これは、開いている場合は渡すことができ、閉じている場合はブロックします。コードは次のとおりです。

public class GateBlocking {

  final class Sync extends AbstractQueuedSynchronizer {
    public Sync() {
      setState(0);
    }

    @Override
    protected int tryAcquireShared(int ignored) {
      return getState() == 1 ? 1 : -1;
    }

    public void reset(int newState) {
      setState(newState);
    }
  };

  private Sync sync = new Sync();

  public void open() {
    sync.reset(1);
  }

  public void close() {
    sync.reset(0);
  }

public void pass() throws InterruptedException {
    sync.acquireShared(1);
  }

};

残念ながら、ゲートが閉じられているためにスレッドがパスメソッドをブロックし、その間に他のスレッドがゲートを開いた場合、ブロックされたスレッドは中断されません-無限にブロックされます。これを示すテストは次のとおりです。

public class GateBlockingTest {

    @Test
    public void parallelPassClosedAndOpenGate() throws Exception{
        final GateBlocking g = new GateBlocking();
        Thread t = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    Thread.sleep(2000);
                    g.open();
                } catch (InterruptedException e) {
                }
            }
        });


        t.start();
        g.pass();
    }
}

ゲート通過スレッドがロックを正常に取得できるようにするには、何を変更すればよいですか。

4

1 に答える 1

2

状態を変更するだけのように見えますsetState()が、ブロックされたスレッドに変更を通知しません。

したがって、代わりに取得/解放メソッドを使用する必要があります。

@Override
protected boolean tryReleaseShared(int ignored) {
    setState(1);
    return true;
}
...
public void open() {
   sync.releaseShared(1);
}

したがって、の全体的なワークフローはAbstractQueuedSynchronizer次のようになります。

  • クライアントはpublicacquire/releaseメソッドを呼び出します

  • これらのメソッドは、すべての同期機能を調整し、実際のロックポリシーをprotected try*()メソッドに委任します

  • //protected try*()を使用してメソッドでロックポリシーを定義しますgetState()setState()compareAndSetState()

于 2012-12-07T14:43:07.213 に答える