为什么不能得到张老师视频中的结果呢？

1. import java.util.Random;import java.util.concurrent.Executors;
   
2. import java.util.concurrent.locks.ReentrantReadWriteLock;
   
3. 
   
4. public class ReaderWriterTest {
   
5.         public static void main(String[] args){
   
6.                 final Queue q = new Queue();
   
7.                 Executors.newFixedThreadPool(3).execute(new Runnable(){
   
8.                         //创建线程池定义3个线程
   
9.                         public void run(){
   
10.                                 while(true)
    
11.                                 {
    
12.                                         q.get();
    
13.                                 }
    
14.                         }
    
15.                 });
    
16.                
    
17.                 for(int i = 0;i<3;i++){
    
18.                         //创建3个线程
    
19.                         new Thread(){
    
20.                                 public void run(){
    
21.                                         while(true){
    
22.                                                 q.put(new Random().nextInt(1000));
    
23.                                         }
    
24.                                 }
    
25.                         }.start();
    
26.                 }
    
27.         }
    
28. }
    
29. 
    
30. class Queue{
    
31.         private Object data = null;
    
32.         //定义私有的data数据
    
33.         private ReentrantReadWriteLock rwl = new ReentrantReadWriteLock();
    
34.         //定义私有的读写锁
    
35.         public void put(Object data){
    
36.                 rwl.writeLock().lock();
    
37.                 //使用写锁
    
38.                 try {
    
39.                         //打印put方法运行的当前线程和状态
    
40.                         System.out.println(Thread.currentThread().getName() + "ready to write");
    
41.                         Thread.sleep(1000);
    
42.                         this.data = data;
    
43.                         System.out.println(Thread.currentThread().getName() + "has write" + data);
    
44.                 } catch (InterruptedException e) {
    
45.                         e.printStackTrace();
    
46.                 }
    
47.                 finally{
    
48.                         rwl.writeLock().unlock();
    
49.                         //释放写锁
    
50.                 }
    
51.                
    
52.         }
    
53.         
    
54.         public void get(){
    
55.                 rwl.readLock().lock();
    
56.                 //使用读锁
    
57.                 try {
    
58.                         //打印get方法运行的当前线程和状态
    
59.                         System.out.println(Thread.currentThread().getName() + "ready to read");
    
60.                         Thread.sleep(1000);
    
61.                         System.out.println(Thread.currentThread().getName() + "has read" + data);
    
62.                 } catch (InterruptedException e) {
    
63.                         e.printStackTrace();
    
64.                 }
    
65.                 finally{
    
66.                         rwl.readLock().unlock();
    
67.                         //释放读锁
    
68.                 }
    
69.         }
    
70. }

复制代码

线程池中创建了3个线程来读取，为什么运行结果中只有一个线程在运行呢？

试运行三个线程都可以运行