no message

programTang · programTang · commit 64c66e2d82af · 2016-08-23T15:58:20.000+08:00
diff --git a/src/main/java/org/tj/study/thread/pipe/Piped.java b/src/main/java/org/tj/study/thread/pipe/Piped.java
@@ -1,7 +1,49 @@
 package org.tj.study.thread.pipe;
 
+import java.io.IOException;
+import java.io.PipedReader;
+import java.io.PipedWriter;
+
 /**
  * Created by 001 on 16/8/23.
  */
 public class Piped {
+
+    public static void main(String[] args) throws IOException {
+        PipedReader reader = new PipedReader();
+        PipedWriter writer = new PipedWriter();
+        writer.connect(reader);
+        new Thread(new Print(reader),"reader1").start();
+        int receive = 0;
+
+        try {
+            while ((receive = System.in.read()) != 0){
+                writer.write(receive);
+            }
+        } finally {
+            writer.close();
+        }
+    }
+
+
+    static class Print implements Runnable{
+
+        private PipedReader in;
+
+        public Print(PipedReader in){
+            this.in = in;
+        }
+
+        @Override
+        public void run() {
+            int receive = 0;
+            try {
+                while ((receive = in.read()) != 0){
+                    System.out.print((char)receive);
+                }
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+    }
 }
diff --git a/src/main/java/org/tj/study/thread/produceconsumer/Consumer.java b/src/main/java/org/tj/study/thread/produceconsumer/Consumer.java
@@ -3,5 +3,20 @@
 /**
  * Created by 001 on 16/8/23.
  */
-public class Consumer {
+public class Consumer implements Runnable
+{
+
+    Product product;
+    int num;
+
+    public Consumer(Product product,int num){
+        this.product = product;
+        this.num = num;
+    }
+
+    @Override
+    public void run() {
+        product.consume(num);
+    }
+
 }
diff --git a/src/main/java/org/tj/study/thread/produceconsumer/Producer.java b/src/main/java/org/tj/study/thread/produceconsumer/Producer.java
@@ -3,5 +3,18 @@
 /**
  * Created by 001 on 16/8/23.
  */
-public class Producer {
+public class Producer implements Runnable{
+
+    Product product;
+    int num;
+
+    public Producer(Product product,int num){
+        this.product = product;
+        this.num = num;
+    }
+
+    @Override
+    public void run() {
+        product.produce(num);
+    }
 }
diff --git a/src/main/java/org/tj/study/thread/produceconsumer/Product.java b/src/main/java/org/tj/study/thread/produceconsumer/Product.java
@@ -1,7 +1,70 @@
 package org.tj.study.thread.produceconsumer;
 
+import org.tj.study.thread.ticket.one.ThreadA;
+
 /**
  * Created by 001 on 16/8/23.
  */
 public class Product {
+
+    Storage storage = new Storage();
+    final int MAX_STOARGE = 50;
+
+    private class Storage{
+        int storage = 0;
+        private void produce(int num){
+            this.storage+=num;
+            System.out.println(Thread.currentThread().getName()+" 产生了 "+num+" , 还剩 "+storage );
+
+        }
+
+        private void comsume(int num){
+            this.storage-=num;
+            System.out.println(Thread.currentThread().getName()+" 消费了 "+num+" , 还剩 "+storage );
+        }
+
+        public int getStorage() {
+            return storage;
+        }
+
+        public void setStorage(int storage) {
+            this.storage = storage;
+        }
+    }
+
+    public void produce(int num){
+//      如果库存容量无限 直接生产  否则当前库存＋num 大于最大库存  无法生产 生产者等待
+        synchronized (storage){
+            while (storage.getStorage()+num>MAX_STOARGE){
+                try {
+                    System.out.println(Thread.currentThread().getName()+" 生产者进入等待状态，想生产: "+num+"  库存: "+storage.getStorage()+" 剩余库存"+(MAX_STOARGE - storage.getStorage()));
+                    storage.wait();
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+            }
+            storage.produce(num);
+//            叫醒消费线程起来消费
+            storage.notifyAll();
+        }
+    }
+
+    public void consume(int num){
+        synchronized (storage){
+            while (storage.getStorage()<num){
+//              库存小于消费的数量 等待
+                try {
+                    System.out.println(Thread.currentThread().getName()+" 消费者进入等待状态，想消费: "+num+"  库存: "+storage.getStorage());
+                    storage.wait();
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+            }
+//            消费
+            storage.comsume(num);
+            storage.notifyAll();
+        }
+    }
+
+
 }
