При создании 10 потоков тех которые делают +1 и тех кто делает -1 синхронизированного числа ( ограничение до >= 0 и <= 5 в ином случает тот кто забирает или тот кто кладёт блокируется ), происходит проблема в том что, рано или поздно зацикливается один "Producer" или "Consumer" и вечно выскакивает сообщение что он был остановлен, чаще всего это происходит, когда число доходит до 0, имею предположение, что я плохо знаком с concurrent.locks и использую его неправильно, либо где то в логике ошибка, так же потоки почему то не понимают, что когда число уже равно 5 его нельзя прибавлять и нужно блокироваться, но происходит так, что они всё равно увеличивают число и не блокирует.
import java.util.*;
import java.util.concurrent.locks.ReentrantLock;
public class stream {
static int number=0;
public static void main(String[] args) throws IllegalMonitorStateException, InterruptedException {
ReentrantLock locker = new ReentrantLock();
var consumer = new ArrayList<Thread>();
var producer = new ArrayList<Thread>();
for (int i = 0; i < 10; i++) {
consumer.add(new Thread(new Consumer(locker)));
producer.add(new Thread(new Producer(locker)));
}
consumer.forEach(Thread::start); //потребитель
producer.forEach(Thread::start); //поставщик
System.out.println("main finished");
}
public static synchronized void put(){
number++;
}
public static synchronized void pick(){
number--;
}
public static synchronized void print(){
System.out.println(number);
}
}
class Consumer implements Runnable{
ReentrantLock locker;
public Consumer(ReentrantLock lock) {
this.locker=lock;
}
@Override
public void run() {
try {
for(;;) {
if (stream.number == 4){
Thread.sleep(1000);
}
Thread.sleep(500);
if (stream.number >= 5) {
System.out.println("Consumer " + Thread.currentThread().getName() + " was stopped ");
locker.lock();
}
else {
if(locker.tryLock()){
locker.unlock();
System.out.println("Consumer " + Thread.currentThread().getName() + " was continued");
}
stream.put();
System.out.println("Consumer " + Thread.currentThread().getName() + " was put product ");
System.out.print("Status product: ");
stream.print();
Thread.sleep(1000);
}
}
} catch (Exception e) {
}
}
}
class Producer implements Runnable{
ReentrantLock locker;
public Producer(ReentrantLock lock) {
this.locker=lock;
}
@Override
public void run() {
try {
Thread.sleep(500);
for(;;) {
if (stream.number == 1){
Thread.sleep(1000);
}
if (stream.number <= 0) {
System.out.println("Producer "+ Thread.currentThread().getName() + " was stopped ");
locker.lock();
}
else {
if(locker.tryLock()){
locker.unlock();
System.out.println("Producer "+ Thread.currentThread().getName() + " was continued");
}
Thread.sleep(1000);
stream.pick();
System.out.println("Producer " + Thread.currentThread().getName() + " was picked up product ");
System.out.print("Status product: ");
stream.print();
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
} [![введите сюда описание изображения][1]][1]
[![введите сюда описание изображения][2]][2]
[1]: https://i.stack.imgur.com/XyMss.png
[2]: https://i.stack.imgur.com/xga2u.png