多线程并发练习

package com.gxnu.bigdata.study.concurrent;

import java.util.Random;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

import org.junit.Test;

public class  {
	
	public static void main(String[] args) {
		BlockingQueue<Integer> bq = new ArrayBlockingQueue<>(10);
		new Thread(()->{
			Random random = new Random();
			while(true){
				int num = random.nextInt(101);
			try {
				bq.put(num);
				Thread.sleep(100);
				System.out.println("生产者："+num);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}}).start();
		
		new Thread(()->{
			while(true){
			try {
				int take = bq.take();
				System.out.println("消费者："+take);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}}).start();
	}
}