刚刚被一个问题卡住了，如果consumer执行notify之后释放了锁，那还怎么return 呀？后面查了一下才知道，notify()或者notifyAll()调用时并不会真正释放对象锁, 必须等到synchronized方法或者语法块执行完才真正释放锁。

写一下代码中老师提出的问题1：while换成if会怎么样 public T consume() throws InterruptedException { synchronized (tasks) { // 如果不用while用if，会怎么样？ if (tasks.size() == 0) { System.out.println("消费者线程进入等待： " + Thread.currentThread().getName()); tasks.wait(); } T ret = tasks.poll(); tasks.notifyAll(); return ret; } } 如果consumer-1由于队列空了释放锁，之后consumer-2抢到了锁也因为队列空了释放锁，之后consumer-3抢到了锁也因为队列空了释放了锁。之后producer-1写入了数据，进而notifyAll()唤醒了所有线程。之后conusmer-1抢到了锁，并从wait()后开始执行，把唯一的数据消费出来并处理，之后consumer-2抢到了锁，由于其从wait()之后开始执行，且这里是if，所以其不再循环，不再判断队列中是否有数据，而是继续向下执行。那么就会出问题。 发生这个问题的本质是： 在多线程的环境下，线程进入WAITING状态前和被唤醒后，线程所处的环境是随机的，谁都不知道多个consumer和多个producer运行过后，队列中的数据究竟是什么样的，队列中的情况是随机的。而如果wait()的调用如果被if包裹，那么就只会执行一次，即调用wait()前检查，但是被唤醒后就不再检查了。也就是说，我们放任consumer-2线程被唤醒后不对队列中的状态进行检查，就继续进行消费动作。 所以得到的结论是： 如果wait()的调用是基于某些条件才调用的，即在特定条件下要让线程进入WAITING状态，那么一定要用while()包括wait()的调用，以便在被唤醒后仍然可以再次进行条件检查。 问题2：如果while检查在synchronized代码块外面： public void produce(T task) throws InterruptedException { while (tasks.size() >= maxTaskCount) { synchronized (tasks) { System.out.println("生产者线程进入等待: " + Thread.currentThread().getName()); tasks.wait(); } } tasks.add(task); tasks.notifyAll(); } 比如下述代码不是基于现在的producer和consumer情景，只是多个线程同时操作一个对象，执行的操作都一样。只是单纯的竞争锁，不区分写和读。 那么就会出现这种情况，所有线程满足条件的时候，就会一个一个进入到synchronized代码块，然后纷纷进入WAITING状态。那么就没人唤醒其他线程了。 这种问题的本质在于： 所有线程可以同时执行到while的条件判断，假设这发生在A时刻，那么此时所有线程都判断要进入WAITING状态，然后thread-1抢到锁，进入WAITING状态，之后thread-2抢到锁，进入WAITING状态，之后thread-3...... 但其实thread-2应该在其抢到锁的时候再去判断此时此刻，是否满足要进入WAITING状态的条件。而不是先在时刻A进行判断，然后抢到锁就进入WAITING。 所以线程要抢到锁再判断是否满足进入WAITING状态的条件。这样的判断是基于当下的，而不是之前某时刻的判断。 所以得到的结论是： 如果要基于某个条件判断是否要让线程进入WAITING状态，那么要让判断条件在synchronized代码块中，这样做的判断才是基于当下进行的判断。

他这个用tasks做锁那能不能直接用this做锁呢

部分2： public class AppMain { public static void main(String[] args) { Queue<String> tasks = new LinkedList<>(); Thread conusmer = new Thread(new Consumer<String>(tasks), "conusmer"); Thread producer = new Thread(new Producer<String>(tasks, 1024), "producer"); conusmer.start(); producer.start(); } } 基于老师的代码例子，我发现了一个问题，producer-1执行完后可能是consumer-1抢到锁执行，也可能是另外一个producer-2抢到锁执行。 但是我想实现的例子是这样的情况，我在producer中输入一行字符串到队列，然后让立刻一个conusmer线程消费并打印。consumer消费完后，立即WAIT，并让producer继续往队列里写字符串，之后再次激活consumer消费。也就是说producer和consumer你执行一次我执行一次。 另外，我把制造数据和往队列里放这两个行为都放到了producer里，把处理数据和从队列里拿数据两个行为都放到了consumer里。 问题1： 我在producer和consumer的run方法中，都是这样的执行顺序： 1.执行往队列里写数据或者从队列里拿数据的操作 2.之后notify()处于WAITING状态的所有线程 3.之后让拿到锁的线程进入WAITING状态 运行后发现达到了目的，效果还不错，但多线程的执行顺序太乱，我不敢保证100%不会出问题，所以麻烦老师看一下，这样的调用有没有问题？会不会发生前面说的那种notify()在wait()之前调用的情况？ 2.问题2： 上面Consumer的代码中，有两个while判断，其中while(true)的while和synchronized可以互换位置吗？ 我自己感觉是可以的，因为while的条件始终都是true，且while执行的代码和synchronized要执行的主要的代码没有区别。而且自己也没有想出来在什么执行次序下回发生问题。老师觉得可以互换位置吗？ 3.学习多线程到现在的感受： 最大的问题就是多个线程的执行顺序是任意的，天知道上一次或下一次会怎么执行，就感觉心虚，没有不带多线程的代码那样指哪打哪的感觉。老师有没有什么使用多线程的窍门？

老师，我自己重新实现了消费者生产者的代码，还是字数有点多，我把内容分成了两部分， 部分1如下： public class Consumer<T> implements Runnable{ private Queue<T> tasks; public Consumer(Queue<T> tasks) { this.tasks = tasks; } private void process(T task) throws InterruptedException { System.out.println("开始处理..."); System.out.println("输入的字符串为：" + task); Thread.sleep(TimeUnit.SECONDS.toMillis(1)); System.out.println("处理结束..."); System.out.println(); } @Override public void run() { synchronized (tasks) { // 这里的while和synchronized换换位置有什么差别吗？ while (true) { try { while (tasks.size() == 0) { tasks.wait(); } process(tasks.poll()); tasks.notifyAll(); tasks.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } } } } *************************************** public class Producer<T> implements Runnable{ private Queue<T> tasks; private int tasksMaxCount; private Scanner scanner; public Producer(Queue<T> tasks, int tasksMaxCount) { this.tasks = tasks; this.tasksMaxCount = tasksMaxCount; scanner = new Scanner(System.in); } private T produce() { System.out.println("请输入字符串："); return (T)scanner.nextLine(); } @Override public void run() { synchronized (tasks) { while (true) { try { while (tasks.size() >= tasksMaxCount) { tasks.wait(); } tasks.add(produce()); tasks.notifyAll(); tasks.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } } } } ****************************

回答代码中注释的问题： // 如果想给生产者消费做一个统计，统计每个生产者消费者所生产/消费的task数量，应该 // 1.使用哪种数据结构 // 2.如何保证线程安全 // 3.怎么将统计结果输出到控制台？ 1.如果要给其统计生产和消费的数量，就需要找一个单独属于某个线程的变量。 线程栈是属于线程的，但线程栈里的栈帧执行完就弹出了，不长久。而堆中的数据所有线程都可以访问，又满足不了单独属于某个线程的变量。 2.如何保证线程安全： 目前已经学习的线程同步控制有synchronized，如果访问同一个变量的线程有分为生产和消费的关系，那么就在synchronized的基础上加入wait和notify。 3.将统计的数量输出到控制台： 由于新建的线程都继承创建线程的System.in,System.out,System.err。所以输出到控制的问题直接System.out.println()就好了。 老师，不知道回答的对不对

老师我运行了给的代码，但消费者有的出现了两次，例如消费者线程进入等待:消费者-98 这是正常的吗？

老师tasks.wait();是把队列里的所有线程都一块进入到wait状态吗？那如果再次执行tasks.wait.()会对之前就存在的线程且已经进入wait状态的线程有影响吗?

老师你好,有几个问题想要请教下 1.代码里面生产者和消费者都是获取 tasks 这一把锁,这样103个线程,同一时刻只能,有一个线程工作,导致的结果就是不能一边add消息,一边pull消息. 要是生产者一把锁,消费一把锁, 是不是就好一点 2.感觉生产者的 notifyAll() 会把生产者wait()等待的也唤醒吧 有点困惑,还请帮忙解答一下,三克油

老师，Queue是个接口，里面定义的方法，为什么可以在这里直接使用？比如add poll这些，并没有默认实现呢