mindol1004/spring-soap
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

JAVA-21602 | fixing sync code block (#14318)

Browse Source
This commit is contained in:
Gaetano Piazzolla
2023-06-28 16:48:08 +02:00
committed by GitHub
parent 930d2fc22a
commit 8d9f1fb8ca
2 changed files with 26 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
core-java-modules/core-java-concurrency-advanced-4/src/main/java/com/baeldung/producerconsumer/Consumer.java
View File

@@ -17,7 +17,6 @@ public class Consumer implements Runnable {
public void consume() {
while (dataQueue.runFlag) {
synchronized (dataQueue) {
while (dataQueue.isEmpty() && dataQueue.runFlag) {
try {
dataQueue.waitOnEmpty();
@@ -32,7 +31,7 @@ public class Consumer implements Runnable {
Message message = dataQueue.remove();
dataQueue.notifyAllForFull();
useMessage(message);
}
}
log.info("Consumer Stopped");
}

3
core-java-modules/core-java-concurrency-advanced-4/src/main/java/com/baeldung/producerconsumer/Producer.java
View File

@@ -19,7 +19,6 @@ public class Producer implements Runnable {
public void produce() {
while (dataQueue.runFlag) {
synchronized (dataQueue) {
while (dataQueue.isFull() && dataQueue.runFlag) {
try {
dataQueue.waitOnFull();
@@ -34,7 +33,7 @@ public class Producer implements Runnable {
Message message = generateMessage();
dataQueue.add(message);
dataQueue.notifyAllForEmpty();
}
}
log.info("Producer Stopped");
}