锁存不同的任务类型

Question

我正在寻找以下问题的Java并发解决方案。有一些任务正在运行，还有一段代码C。C必须等待所有任务完成。（超时）在C完成之前，无法开始任何任务。我浏览了java.concurrency包，发现了一些有趣的东西，但是似乎没有什么工作很正确：移相器将允许一种方式阻塞，但不允许两种方式。信号量，ForkJoinTasks和其他具有计数器类型的功能，但似乎都没有我想要的功能。我相信我可以使用移相器和锁来构造一些东西，如下所示：void C() {    synchronized(lock) {        phaser.awaitAdvanceInterruptibly(phase, 1, TimeUnit.SECONDS);        // Start work anyway if a task is taking too long.        doWork();    }}void someTask() {    synchronized(lock) {        phaser.register();    }    doTask().thenRun(        () -> phaser.arriveAndDeregister()    );}现在，尽管我相当确定这是可行的，但我也知道尝试构建自己的并发解决方案是一个坏主意。有更好的方法吗？如果没有，我将如何使用该phase参数？编辑：此问题是在涉及Web客户端连接的项目中，因此任务无法预测地到达。但是，通过更仔细的设计可以避免这种情况。

Answer 1

我在java.util.concurrent.locks中找到了解决此问题的解决方案，这对我的用例来说是完美的。

StampedLock lock;

void C() {

    long stamp = lock.tryWriteLock(1, TimeUnit.SECONDS);

    doWork();

    lock.unlockWrite(stamp);

}

void someTask() {

    long stamp = lock.readLock();

    doTask().thenRun(() -> lock.unlockRead(stamp));

}

StampedLock类的关键是readLock（）不是互斥的，而writeLock（）是互斥的。它也支持超时，类似于常规的Lock。