我们正在尝试从EC2实例上运行的Java程序读取AmazonSQS队列。有时，我们会收到com.amazonaws.AbortedException。我们的代码如下所示:AmazonSQSClientsqs=newAmazonSQSClient(myCredentials);ReceiveMessageRequestrequest=newReceiveMessageRequest().withWaitTimeSeconds(20).withMaxNumberOfMessages(1).withQueueUrl(queueUrl);ReceiveMessageResultresult=s

我有多个消费者线程使用await()等待大小为1的CountDownLatch。我有一个生产者线程，它在成功完成时调用countDown()。这在没有错误的情况下效果很好。但是，如果生产者检测到错误，我希望它能够向消费者线程发出错误信号。理想情况下，我可以让生产者调用类似abortCountDown()的东西，并让所有消费者收到InterruptedException或其他一些异常。我不想调用countDown()，因为这需要我所有的消费者线程在调用await()之后再进行一次额外的手动检查是否成功。我宁愿他们只收到一个他们已经知道如何处理的异常。我知道CountDownLatch中没