java中在某些条件下阻塞线程

Question

也许这是一个非常愚蠢的问题，但请听我说完。我有一个用例，我收到许多并发请求，要求针对特定输入日期执行某些操作。如果同一输入日期收到两个并发请求，则在前一个请求完全完成之前，后续请求不应继续进行（出于充分的理由）。使用标准 java.util.concurrent 组件来实现此目的的最佳方法是什么？我最初的想法是拥有一个 LockFactory，它将出售锁并保留一个副本以表明它正在使用，并且后续请求将在其上等待（）。然而，这似乎有很多样板代码 - 有什么更简单的技巧让我困惑吗？

提前致谢！

Answer 1

您可以对日期时间的各个锁进行哈希处理。

private static final ConcurrentMap<Long,Lock> dateLock = new ConcurrentHashMap<Long,Lock>();

public static Lock getLock(Date date){
  Lock lock = dateLock.get(date.getTime());  
  if(lock == null){
    Lock lock = new ReentrantLock();  
    Lock temp =dateLock.putIfAbsent(lock); 
    lock = temp == null ? lock : temp;
  }
 return lock;
}

如果您需要同一天，而不一定是以毫秒为单位的确切日期，您可以执行类似“

private static final ConcurrentMap<String,Lock> dateLock = new ConcurrentHashMap<String,Lock>();

public static Lock getLock(Date date){ 
  String formattedDate = new SimpleDateFormat("MM\dd\yyyy").parse(date);
  Lock lock = dateLock.get(formattedDate);  
  if(lock == null){
    Lock lock = new ReentrantLock();  
    Lock temp =dateLock.putIfAbsent(lock); 
    lock = temp == null ? lock : temp;
  }
 return lock;
}

然后任何需要在日期上互斥的请求”

Date date = ...;

Lock lock = getLock(date);
lock.lock(); 

之类的操作

Answer 2

在我看来，您必须将请求排队并一次处理一个。那么也许来自 java.util.concurrent 的 BlockingQueue ？

Answer 3

我假设您已经拥有一个系统，其中线程可以接受输入请求并处理它们，而不会丢失或重复任何内容，从而解决任何锁定问题。然后，您需要的只是每个线程在某处记录其当前正在处理的事情的输入日期。当线程检查输入请求时，它首先检查日期，查看当前是否正在处理具有该日期的任何请求，如果是，则将该请求留在队列中并处理下一个请求。

您将需要一定程度的锁定，以确保在测试时“当前正在处理的条目”不在更新过程中。

Answer 4

您需要创建一个 ThreadPoolExecutor 来在多个线程中执行请求。您还需要有一个现在正在处理的输入日期列表。该列表应该具有同步访问器和 putIfAbsent 方法。在将任务发送到队列之前，请检查其输入日期是否现在尚未处理。如果现在正在处理，则将此任务移至队列末尾并尝试运行下一个任务。任务完成后，从列表中删除其输入日期。

Answer 5

您正在寻找的简单技巧是线程池“按顺序处理”模式。 这是一个线程解释该模式以及实现该模式的各种解决方案