생산자와 소비자의 예(다중 루틴 wait() 및 notify All 응용 프로그램)
package test;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
class Meal {
private final int orderNum;
public Meal(int orderNum) {
this.orderNum = orderNum;
}
public String toString() {
return "Meal " + orderNum;
}
}
class WaitPerson implements Runnable{
private Restaurant restaurant;
public WaitPerson(Restaurant r){
restaurant=r;
}
@Override
public void run() {
try {
while(!Thread.interrupted()){
synchronized (this) {
while(restaurant.meal==null){
wait();
}
}
System.out.println("Waitperson got "+restaurant.meal);
synchronized(restaurant.chef){
restaurant.meal=null;
restaurant.chef.notifyAll();
}
}
} catch (InterruptedException e) {
System.out.println("Waitperson interrupted");
}
}
}
class Chef implements Runnable{
private Restaurant restaurant;
private int count=0;
public Chef(Restaurant r) {
restaurant=r;
}
@Override
public void run() {
try {
while(!Thread.interrupted()){
synchronized (this) {//
while(restaurant.meal!=null){
wait();//
}
}
if(++count==10){
System.out.println("out of food, closing");
restaurant.exec.shutdownNow();
}
System.out.print("Order up!");
synchronized(restaurant.waitPerson){
restaurant.meal=new Meal(count);
restaurant.waitPerson.notifyAll();
}
TimeUnit.MILLISECONDS.sleep(100);
}
} catch (InterruptedException e) {
System.out.println("Chef interrupted");
}
}
}
public class Restaurant {
/**
* @param args
*/
Meal meal;
ExecutorService exec=Executors.newCachedThreadPool();
WaitPerson waitPerson=new WaitPerson(this);
Chef chef=new Chef(this);
public Restaurant(){
exec.execute(chef);// chef
exec.execute(waitPerson);// waitPerson
}
public static void main(String[] args) {
new Restaurant();
}
}
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Java 다중 스레드를 순차적으로 실행하는 몇 가지 방법 요약Java 다중 스레드를 순차적으로 실행하는 몇 가지 방법 요약 동료는 무심결에 이 문제를 제기하고 두 가지 방법을 직접 실천했다.물론 더 좋은 방법이 있을 거야. 방법 1 이런 방법은 비교적 흔히 볼 수 있는 해결 ...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.