1.问题描述

实现Java非阻塞式生产者消费者，用来解决，生产和消费对于资源访问不同步和造成资源冗余的问题

2.实现思想

• 针对于同一资源，生产者生产前会前检测资源是否大于0，如果大于0，则生产者线程释放资源锁，进入waiting阶段，如果小于0，则生产者线程持有锁，并且生产资源，生产一定资源之后，通知消费者。
• 消费者线程，去消费之前，会检测资源是否大于0，如果小于0，则阻塞等待，并且通知生产者生产资源，如果大于0，则消费资源，消费完成，唤醒生产者，生产资源。
• 这样就实现了每次生产者生产都是生产一定的资源，等待消费者消费完成之后，才去继续生产

3.代码

3.1使用wait、notify

import java.util.ArrayList;import java.util.List;import java.util.Random;public class Main {public static class Breads {private List<Integer> bordIntegers = new ArrayList<Integer>();public synchronized void add() {if (bordIntegers.size() > 0) {System.out.println("生产者检测到目前资源大于0，不生产");try {wait();} catch (InterruptedException e) {e.printStackTrace();}}System.out.println("生产者检测到目前资源小于0，开始生产");for (int i = 0; i < 5; i++) {bordIntegers.add(new Random().nextInt(1000));}try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}notify();}public synchronized void del() {if (bordIntegers.size() <= 0) {System.out.println("消费者检测到目前资源小于0，通知生产者");try {wait();} catch (InterruptedException e) {e.printStackTrace();}}System.out.println("消费者检测到目前资源大于0，开始消费");for (int i = 0; i < bordIntegers.size(); i++) {System.out.println(bordIntegers.get(i));}bordIntegers.clear();try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}notify();}}public static void main(String[] args) {Breads borad = new Breads();Thread createThread = new Thread(new Runnable() {@Overridepublic void run() {while (true) {borad.add();}}});Thread consumethread = new Thread(new Runnable() {@Overridepublic void run() {while (true) {borad.del();}}});createThread.start();consumethread.start();System.out.println("Main Thread exit!");}}

3.2使用ArrayBlockingQueue

import java.util.concurrent.ArrayBlockingQueue;public class Main {static ArrayBlockingQueue<Integer> bordBlockingQueue = new ArrayBlockingQueue<Integer>(10);public static void main(String[] args) {Thread createThread = new Thread(new Runnable() {@Overridepublic void run() {while (true) {for (int i = 0; i < 10; i++) {try {bordBlockingQueue.put(i);System.out.println("生产者生产");} catch (InterruptedException e) {e.printStackTrace();}}}}});Thread consumethread = new Thread(new Runnable() {@Overridepublic void run() {while (true) {while (!bordBlockingQueue.isEmpty()) {try {System.out.println("消费者消费");bordBlockingQueue.take();} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}}});createThread.start();consumethread.start();System.out.println("Main Thread exit!");}}

墨言文学成语大全