Java并发 - 是否有反向的CountDownLatch？

Question

有一些用户激活的长时间运行的任务在后台执行。由于系统是多用户的，因此知道在任何给定时间可能运行的数量是不切实际的。

通常，这些任务可以在后台执行，并在完成后完成。某些有限的用户操作需要在继续之前完成所有此类任务。需要阻塞同步机制。我实现了这样做的逻辑，但意识到我需要的行为实际上与CountDownLatch相反：

• 当一个允许的任务（在我的情况下，一个后台任务）执行时，它将增加计数无限制（或有界）
• 完成后会减少计数
• 会有阻塞方法只在count> 0时阻塞

我在java.util.concurrent中找不到这样的类。有谁知道这样的东西是否存在于任何地方？

Answer 1

如果有人想知道我最终做了什么，请记录下面：

我最终需要两个锁：

    this.workInProgressLock = new ReentrantReadWriteLock(true);
    this.singleFileLock = new Semaphore(1, true);

ReadWriteLock主要按照上面的注释中的描述工作。主要问题是writeLock请求在他们待定时优先考虑。因此，排序不像应该那样容易控制。

信号量确实计数，但我需要的是相反的。我为什么要加一个？我很快意识到后台处理（任务）是一条双向的街道！如最初描述的那样，允许后台进程在需要时启动。在应用程序的某些“关键部分”运行时，出现了重大问题。因此，App端需要一种“锁定”后台任务的方法。单计数信号量非常适合这个目的。

在某个地方有一个“BackgroundProcessingLock”会很好（Guava，在哪里）：

public interface BackgroundProcessingLock {

    void allowBackgroundTasks();

    void preventBackgroundsTasks(boolean wait);  

    void wait();  // simply waits until all background tasks complete

    void startBackgroundTask();

    void completeBackgroundTask();

    void setMaxNumberOfBackgroundTasks(int maxParallelBackgroundTasks);

}  

Answer 2

您可以使用AtomicInteger并使用synchronized和内置的wait() / notify()构造来等待其锁定。