У меня есть два потока. Один из них - клиент, а другой - продукт.Как смоделировать функцию блокировки с помощью Java
Я хочу вызвать функцию у клиента под названием READ. Это должно блокироваться бесконечно, пока производитель не поместит на него данные.
Как я могу это сделать? Спасибо!
Я бы рекомендовал вам использовать LinkedBlockingQueue. Это самый простой способ моделирования проблемы «производитель-консумент». Один поток помещает значения в очередь с использованием метода put, а другой потребляет данные, используя take, который блокирует (поток ждет, пока очередь не будет пустой). Использование LinkedBlockingQueue очень просто, потому что вам не нужно синхронизировать свои методы. Все уже сделано.
Да ... нет необходимости изобретать велосипеды. (Особенно квадратные, которые используют ожидание.) –
На самом деле, я думаю, что любой 'BlockingQueue' будет делать, не так ли? – OldCurmudgeon
Overkill для этого. Вы можете использовать ReentrantLock или Sempahore, оба из которых являются гораздо более простыми подходами и будут иметь больше смысла для кого-то, читающего код. – Matt
Использовать thread.wait(), а затем thread.notify(). thread.wait() ждет до thread.notify().
уведомлять или уведомлять все? Как насчет мониторов? и т. д. Это очень низкий уровень, и его следует избегать, если это возможно. – assylias
-1 - И если «уведомление» происходит сначала, весь процесс выходит из строя. Когда люди перестанут рекомендовать архаичные и сломанные решения уже разрешенных проблем !!! – OldCurmudgeon
если данные, которые должны быть помещены в очередь, требуют синхронизации, то есть производитель создает один объект и сохраняет его в очереди; потребитель должен взять объект, поставленный производителем, используя SynchronousQueue или новую TransferQueue, должна быть лучшая идея.
[Что вы пытались?] (http://whathaveyoutried.com) –
Использование блоков синхронизации, но было занято в ожидании – bratao