MyNumber
import java.util.concurrent.LinkedBlockingQueue;
public class MyNumber {
public static LinkedBlockingQueue<Integer> queen=new LinkedBlockingQueue<Integer>();
}
Customer
public class Customer extends Thread {
@Override
public void run() {
while(true){
try {
int num=MyNumber.queen.take();
System.out.println("消费者: "+num);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
Producer
import java.util.Random;
public class Producer extends Thread {
@Override
public void run() {
while(true){
try {
int num=getNum();
MyNumber.queen.put(num);
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
private static int getNum(){
Random ra =new Random();
int a=ra.nextInt(9);
return a;
}
}
Test
public class Test {
public static void main(String[] args) {
Customer c=new Customer();
Producer p=new Producer();
c.start();
p.start();
}
}
纯手写,希望时间来的及,楼主采纳一下吧
追问谢谢谢谢,我试一下