黑马程序员技术交流社区

标题: 求解阻塞队列中的同步问题？ [打印本页]
作者: 静以修身    时间: 2013-9-24 20:57
标题: 求解阻塞队列中的同步问题？
本帖最后由 静以修身 于 2013-9-24 21:00 编辑

问题在代码注释中的

package threadtest;

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

public class BlockingQueueTest {
        public static void main(String[] args) {
                final BlockingQueue queue = new ArrayBlockingQueue(3);
                for(int i=0;i<2;i++){
                        new Thread(){
                                public void run(){
                                        while(true){
                                                try {
                                                        Thread.sleep((long)(Math.random()*1000));
                                                        System.out.println(Thread.currentThread().getName() + "准备放数据!");                                                        
                                                        queue.put(1);   //我的问题是：怎么让这行代码和下一行代码一起执行
                                                        System.out.println(Thread.currentThread().getName() + "已经放了数据，" +                                                         
                                                                                "队列目前有" + queue.size() + "个数据");
                                                } catch (InterruptedException e) {
                                                        e.printStackTrace();
                                                }

                                        }
                                }
                                
                        }.start();
                }
               
                new Thread(){
                        public void run(){
                                while(true){
                                        try {
                                                //将此处的睡眠时间分别改为100和1000，观察运行结果
                                                Thread.sleep(1000);
                                                System.out.println(Thread.currentThread().getName() + "准备取数据!");
                                                queue.take();  //问题：怎么让这行代码和下一行代码一起执行
                                                System.out.println(Thread.currentThread().getName() + "已经取走数据，" +                                                         
                                                                "队列目前有" + queue.size() + "个数据");                                       
                                        } catch (InterruptedException e) {
                                                e.printStackTrace();
                                        }
                                }
                        }
                        
                }.start();                        
        }
}

结果如下：
Thread-0已经放了数据，队列目前有3个数据         //这行和下一行代码之所以打印出3个数据就是因为注释中的两行代码没有一起执行
Thread-2已经取走数据，队列目前有3个数据         //怎样才能让它们一起执行啊，让它们同步，加上synchronized(BlockingQueueTest)不行啊



作者: （0.0）’    时间: 2013-9-24 22:36
  1. import java.util.concurrent.ArrayBlockingQueue;
  2. import java.util.concurrent.BlockingQueue;
  3. public class BlockingQueueTest {
  4.         public static void main(String[] args){
  5.                 final BlockingQueue queue = new ArrayBlockingQueue(3);

  7.                 for(int i=0;i<2;i++){
  8.                         new Thread(){
  9.                                 public void run(){
  10.                                         while(true){
  11.                                                 try{
  12.                                                         Thread.sleep((long)(Math.random()*1000));
  13.                                                         System.out.println(Thread.currentThread().getName() + "准备放数据");
  14.                                                         queue.put(1);//我的问题是：怎么让这行代码和下一行代码一起执行
  15.                                                         System.out.println(Thread.currentThread().getName()+"已放数据,"
  16.                                                         +"目前队列有"+queue.size()+"个数据");
  17.                                                 }catch(InterruptedException e){
  18.                                                         e.printStackTrace();
  19.                                                 }
  20.                                         }
  21.                                 }
  22.                         }.start();
  23.                 }
  24.                 new Thread(){
  25.                         public void run(){
  26.                                 while(true){
  27.                                         try{//将此处的睡眠时间分别改为100和1000，观察运行结果
  28.                                                 Thread.sleep(1000);
  29.                                                 System.out.println(Thread.currentThread().getName()+"准备取出数据，");
  30.                                                 queue.take();//问题：怎么放这行代码和下一行代码一起执行。
  31.                                                 System.out.println(Thread.currentThread().getName()+"已经取走数据，"+
  32.                                                         "队列目前有"+queue.size()+"个数据");
  33.                                         } catch(InterruptedException e){
  34.                                                 e.printStackTrace();
  35.                                         }
  36.                                 }
  37.                         }
  38.                 }.start();
  39.         }
  40. }
  41. /*
  42. Thread-0已经放了数据，队列目前有3个数据                //这行和下一行diamond之所以打印出了饿个数据就是因为注释中的两行代码没有一起执行
  43. Thread-2已经取走数据，队列目前有3个数据                //怎么才能让他们一起执行啊，让他们同步，加上synchronized(BlockingQueueTest)不行啊
  44. */
复制代码
你的代码应该放在代码区这样方便复制，我帮你弄了，希望有同学能帮你解决吧。
作者: 神之梦    时间: 2013-9-24 23:25
  加锁可以解决
作者: 陈洋    时间: 2013-9-24 23:45
楼主看一下，加一个锁。
  1. package cn.itcast.day1;
  2. import java.util.concurrent.ArrayBlockingQueue;
  3. import java.util.concurrent.BlockingQueue;
  4. public class BlockingQueueTest {
  5.         public static void main(String[] args){
  6.                 final BlockingQueue queue = new ArrayBlockingQueue(3);

  8.                 for(int i=0;i<2;i++){
  9.                         new Thread(){
  10.                                 public void run(){
  11.                                         while(true){
  12.                                                 try{
  13.                                                         Thread.sleep((long)(Math.random()*1000));
  14.                                                         System.out.println(Thread.currentThread().getName() + "准备放数据");
  15.                                                         queue.put(1);//我的问题是：怎么让这行代码和下一行代码一起执行
  16.                                                         System.out.println(Thread.currentThread().getName()+"已放数据,"
  17.                                                         +"目前队列有"+queue.size()+"个数据");
  18.                                                 }catch(InterruptedException e){
  19.                                                         e.printStackTrace();
  20.                                                 }
  21.                                         }
  22.                                 }
  23.                         }.start();
  24.                 }
  25.                 new Thread(){
  26.                         public void run(){
  27.                                 while(true){
  28.                                         try{//将此处的睡眠时间分别改为100和1000，观察运行结果
  29.                                                 Thread.sleep(1000);
  30.                                                 System.out.println(Thread.currentThread().getName()+"准备取出数据，");
  31.                                                 
  32.                                                 synchronized (BlockingQueueTest.class) {
  33.                                                                                                         queue.take();//问题：怎么放这行代码和下一行代码一起执行。
  34.                                                                                                         System.out.println(Thread.currentThread().getName()+"已经取走数据，"+
  35.                                                         "队列目前有"+queue.size()+"个数据");
  36.                                                                                                 }
  37.                                                 
  38.                                         } catch(InterruptedException e){
  39.                                                 e.printStackTrace();
  40.                                         }
  41.                                 }
  42.                         }
  43.                 }.start();
  44.         }
  45. }
  46. /*
  47. Thread-0已经放了数据，队列目前有3个数据                //这行和下一行diamond之所以打印出了饿个数据就是因为注释中的两行代码没有一起执行
  48. Thread-2已经取走数据，队列目前有3个数据                //怎么才能让他们一起执行啊，让他们同步，加上synchronized(BlockingQueueTest)不行啊
  49. */
复制代码
作者: freehiker    时间: 2013-9-25 00:23
你可以给那两句话上加上
  1. synchronized(BlockingQueueTest.class)
  2. {
  3.      那两句代码的位置
  4. }
复制代码
记得两个线程都要加，一样的
我加了测试时候，是能满足你的要求的，但是会执行一段时间后会停着，不知道是否是其他代码的原因，里面有些代码我还不认识 {:soso_e113:}
作者: 静以修身    时间: 2013-9-25 12:08
freehiker 发表于 2013-9-25 00:23
你可以给那两句话上加上记得两个线程都要加，一样的
我加了测试时候，是能满足你的要求的，但是会执行一段 ...

加了锁我也测试过，有行的也有不行的。前面打印出的那部分正常了，没有问题，但后面打印的又出现了原来的问题。还有如果两个线程都加的话会出现死锁的情况。比如当队列里已经有三个数据的时候，添加数据的线程抢到锁，这时因为队列已满不能添加会阻塞在线程里面，而又没有释放锁，导致获取数据的线程不能获取数据，因为添加数据的线程霸占了锁，这样会导致死锁啊。{:soso_e101:}




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