分析:
- 是否为多线程问题:是,生产者线程/消费者线程
- 是否有共享数据:有,产品/店员
- 如何解决线程安全问题?同步机制,三种方法
- 是否涉及到线程的通信? 是
class Clerk{
private int productCount = 0;
public synchronized void costomProduct(){
if(productCount < 20){
productCount++;
System.out.println(Thread.currentThread().getName() + ":开始生产第" + productCount +"个产品" );
//只要生产者生产一个产品,消费者就可以消费了
notify();
}else{
//等待
wait();//alt enter处理异常
}
}
public synchronized void produceProduct(){
if(productCount > 0){
System.out.println(Thread.currentThread().getName() + ":开始消费第" + productCount +"个产品" );
productCount--;
notify();
}else{
//等待
wait();//alt enter处理异常
}
}
class Producer extends Thread{
private Clerk clerk;//声明clerk类型的变量
//构造器alt+shift+s调用父类的空参
public Poducer(Clerk clerk){
this.clerk = clerk;
}
@Override
public void run{
System.out.println(Thread.currentThread().getName() + ":开始生产产品" );
while(true){
clerk.produceProduct();
}
}
class Customer extends Thread{
private Clerk clerk;//声明clerk类型的变量
//构造器alt+shift+s调用父类的空参
public Customer(Clerk clerk){
this.clerk = clerk;
}
@Override
public void run{
System.out.println(Thread.currentThread().getName() + ":开始消费产品" );
while(true){
clerk.costomProduct();//没有就用Alt +enter造一个
}
}
}
public class ProductTest {
public static void main(String[] args) {
Clerk clerk = new Clerk();
Poducer p1 = new Poducer();
p1.setName("生产者1")
Customer c1 = new Customer();
p1.setName("消费者1");
p1.start();
c1.start();
}
}