黑马程序员技术交流社区

标题: 发一个今天的练习 [打印本页]
作者: noiary    时间: 2014-9-13 23:55
标题: 发一个今天的练习
多线程略难,时间也少. 第十二天,两天了还没吃透.

不过我想,多线程应该是java中的重点,学好这里下面才会相对轻松些...

很期待13天的String ~


  2. /*
  3. 生产者消费者练习
  4. synchronized版

  6. */

  8. public class ProducerConsumerDemo {

  10.         public static void main(String[] args) {
  11.        
  12.                 Resource res = new Resource();
  13.                
  14.                 new Thread(new Producer(res)).start();
  15.                 new Thread(new Producer(res)).start();
  16.                 new Thread(new Consumer(res)).start();
  17.                 new Thread(new Consumer(res)).start();
  18.         }
  19. }

  21. class Resource {
  22.        
  23.         private String name;
  24.         private int count = 1;
  25.         private boolean flag;

  27.         public synchronized void set(String name) {
  28.        
  29.                 while(flag)
  30.                         try{wait();} catch(Exception e) {}
  31.                 this.name = name + "--" + count++;
  32.                 System.out.println(Thread.currentThread().getName() + "\t生产者" + this.name);
  33.                 flag = true;
  34.                 notifyAll();
  35.         }
  36.        
  37.         public synchronized void out() {
  38.        
  39.                 while(!flag)
  40.                         try{wait();} catch(Exception e) {}
  41.                 System.out.println(Thread.currentThread().getName() + "\t\t消费者" + this.name);
  42.                 flag = false;
  43.                 notifyAll();
  44.         }
  45. }


  48. class Producer implements Runnable {

  50.         Resource res;
  51.        
  52.         public Producer(Resource res) {
  53.        
  54.                 this.res = res;
  55.         }
  56.        
  57.         public void run() {
  58.        
  59.                 while(true) {
  60.                
  61.                         res.set("商品");
  62.                 }
  63.         }
  64. }

  66. class Consumer implements Runnable {

  68.         Resource res;
  69.        
  70.         public Consumer(Resource res) {
  71.        
  72.                 this.res = res;
  73.         }
  74.        
  75.         public void run() {
  76.        
  77.                 while(true) {
  78.                
  79.                         try{Thread.sleep(500);} catch(Exception e) {}
  80.                         res.out();
  81.                 }
  82.         }
  83. }
复制代码


  1. import java.util.concurrent.locks.*;


  4. /*
  5. 生产者消费者练习
  6. ReentrantLock版

  8. */
  9. public class ProducerConsumerDemo2 {

  11.         public static void main(String[] args) {
  12.        
  13.                 Resource res = new Resource();
  14.                
  15.                 new Thread(new Producer(res)).start();
  16.                 new Thread(new Producer(res)).start();
  17.                 new Thread(new Consumer(res)).start();
  18.                 new Thread(new Consumer(res)).start();
  19.         }
  20. }

  22. class Resource {

  24.         private String name;
  25.         private int count = 1;
  26.         private boolean flag;
  27.        
  28.         private Lock lock = new ReentrantLock();
  29.         private Condition condition_pro = lock.newCondition();
  30.         private Condition condition_con = lock.newCondition();
  31.        
  32.         public void set(String name)
  33.                 throws InterruptedException {
  34.        
  35.                 lock.lock();
  36.                 try {
  37.                
  38.                         if(flag)
  39.                                 condition_pro.await();
  40.                         this.name = name + "--" + count++;
  41.                         System.out.println(Thread.currentThread().getName() + "生产者" + this.name);
  42.                         flag = true;
  43.                         condition_con.signal();
  44.                 }
  45.                 finally {
  46.                
  47.                         lock.unlock();
  48.                 }
  49.         }
  50.        
  51.         public void out()
  52.                 throws InterruptedException {
  53.        
  54.                 lock.lock();
  55.                 try {
  56.                
  57.                         if(!flag)
  58.                                 condition_con.await();
  59.                         System.out.println(Thread.currentThread().getName() + "\t\t消费者" + this.name);
  60.                         flag = false;
  61.                         condition_pro.signal();
  62.                 }
  63.                 finally {
  64.                
  65.                         lock.unlock();
  66.                 }
  67.         }
  68. }



  72. class Producer implements Runnable {

  74.         Resource res;
  75.        
  76.         public Producer(Resource res) {
  77.        
  78.                 this.res = res;
  79.         }
  80.        
  81.         public void run() {
  82.        
  83.                 while(true) {
  84.                
  85.                         try {
  86.                                
  87.                                 res.set("商品");
  88.                         }
  89.                         catch(InterruptedException e) {
  90.                        
  91.                         }
  92.                 }
  93.         }
  94. }

  96. class Consumer implements Runnable {

  98.         Resource res;
  99.        
  100.         public Consumer(Resource res) {
  101.        
  102.                 this.res = res;
  103.         }
  104.        
  105.         public void run() {
  106.        
  107.                 while(true) {
  108.                
  109.                         try {
  110.                        
  111.                                 res.out();
  112.                         }
  113.                         catch(InterruptedException e) {
  114.                        
  115.                         }
  116.                 }
  117.         }
  118. }
复制代码
作者: fantacyleo    时间: 2014-9-14 01:12
如果能把张老师的Java并发库视频看完，并用里面的每种工具把生产者消费者问题实现一遍，你的Java多线程就算入门了
作者: ItJack    时间: 2014-9-14 14:46
感谢分享。
作者: noiary    时间: 2014-9-14 22:57
fantacyleo 发表于 2014-9-14 01:12
如果能把张老师的Java并发库视频看完，并用里面的每种工具把生产者消费者问题实现一遍，你的Java多线程就算 ...

好的,一定实践~!  
作者: 暴走的小青春丶    时间: 2014-9-14 23:07
并发库的视频在哪里啊
作者: 不系之舟王    时间: 2014-9-15 00:24
学习一下
作者: 648947721    时间: 2014-9-15 00:55
学习学习



欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2