文章/答案/技术大牛

发布

社区首页 >问答首页 >即使等待条件已经改变，AbstractQueuedSynchronizer.acquireShared也会无限期地等待

问即使等待条件已经改变，AbstractQueuedSynchronizer.acquireShared也会无限期地等待
EN

Stack Overflow用户

提问于 2012-12-07 22:17:30

回答 1查看 167关注 0票数 5

我编写了一个使用AbstractQueuedSynchronizer的简单类。我写了一个表示"Gate“的类，它可以在打开的时候传递，或者在关闭的时候阻塞。代码如下：

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);
  }

};

不幸的是，如果一个线程因为gate被关闭而同时其他线程打开了gate而阻塞了pass方法，那么被阻塞的线程不会被中断-它会无限地阻塞。下面的测试显示了这一点：

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();
    }
}

请帮帮忙，我该怎么做才能让通过gate的线程成功获取锁呢？

java

java.util.concurrent

回答 1

Stack Overflow用户

回答已采纳

发布于 2012-12-07 22:43:07

看起来setState()只更改了状态，但不会通知阻塞的线程更改。

因此，您应该改用获取/释放方法：

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

因此，AbstractQueuedSynchronizer的整体工作流程如下所示：

客户端调用public acquire/release方法
这些方法安排所有同步功能并将实际的锁定策略委托给protected try*()方法
您可以使用protected try*()在protected try*()方法中定义锁定策略

票数 2

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/13764858

复制

相似问题

问即使等待条件已经改变，AbstractQueuedSynchronizer.acquireShared也会无限期地等待
EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问即使等待条件已经改变，AbstractQueuedSynchronizer.acquireShared也会无限期地等待EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问即使等待条件已经改变，AbstractQueuedSynchronizer.acquireShared也会无限期地等待
EN