You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by jo...@apache.org on 2022/12/04 13:21:34 UTC
[incubator-eventmesh] branch master updated: update signal to signalAll (#2451)
This is an automated email from the ASF dual-hosted git repository.
jonyang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new dcd8ea06d update signal to signalAll (#2451)
dcd8ea06d is described below
commit dcd8ea06d482953c66164a7c4579293c63fd016e
Author: weihubeats <we...@163.com>
AuthorDate: Sun Dec 4 21:21:28 2022 +0800
update signal to signalAll (#2451)
---
.../apache/eventmesh/connector/standalone/broker/MessageQueue.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/MessageQueue.java b/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/MessageQueue.java
index ddac489d4..2e561c2f5 100644
--- a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/MessageQueue.java
+++ b/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/MessageQueue.java
@@ -188,7 +188,7 @@ public class MessageQueue {
if (takeIndex == items.length) {
takeIndex = 0;
}
- notFull.signal();
+ notFull.signalAll();
} finally {
lock.unlock();
}
@@ -209,7 +209,7 @@ public class MessageQueue {
putIndex = 0;
}
count++;
- notEmpty.signal();
+ notEmpty.signalAll();
}
private MessageEntity dequeue() {
@@ -217,7 +217,7 @@ public class MessageQueue {
if (takeIndex == items.length) {
takeIndex = 0;
}
- notFull.signal();
+ notFull.signalAll();
return item;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org