karsten.jeppesen/changeTest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ConditionDemo: removed final keyword not to confuse students

Browse Source
This commit is contained in:
Karsten Jeppesen
2021-03-02 19:58:40 +01:00
parent db15919928
commit 6eedc15f4f
3 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
ConditionDemo/src/Consumer.java
View File

@@ -5,10 +5,10 @@ import java.util.HashSet;
import java.util.Set; import java.util.Set;
public class Consumer extends Thread { public class Consumer extends Thread {
private final Set knownObjects = new HashSet(); private Set knownObjects = new HashSet();
private int total = 0; private int total = 0;
private int unique = 0; private int unique = 0;
private final SharedFiFoQueue queue; private SharedFiFoQueue queue;
public Consumer(SharedFiFoQueue queue) { public Consumer(SharedFiFoQueue queue) {
this.queue = queue; this.queue = queue;

4
ConditionDemo/src/Producer.java
View File

@@ -8,8 +8,8 @@ import java.io.FileReader;
import java.io.IOException; import java.io.IOException;
public class Producer extends Thread { public class Producer extends Thread {
private final static String FILENAME = "input.txt"; private static String FILENAME = "input.txt";
private final SharedFiFoQueue queue; private SharedFiFoQueue queue;
public Producer(SharedFiFoQueue queue) { public Producer(SharedFiFoQueue queue) {
this.queue = queue; this.queue = queue;

6
ConditionDemo/src/SharedFiFoQueue.java
View File

@@ -10,9 +10,9 @@ public class SharedFiFoQueue {
private int PosW = 0; private int PosW = 0;
private int PosR = 0; private int PosR = 0;
private final Lock lock = new ReentrantLock(); private Lock lock = new ReentrantLock();
private final Condition isEmpty = lock.newCondition(); private Condition isEmpty = lock.newCondition();
private final Condition isFull = lock.newCondition(); private Condition isFull = lock.newCondition();
public SharedFiFoQueue(int capacity) { public SharedFiFoQueue(int capacity) {
this.elems = new Object[capacity]; this.elems = new Object[capacity];