这段代码运行中会停止，有时候会报异常，把线程创建改成传统方式就没问题。可能是线程池的问题，但是不知道具体什么问题。求真相。

1. import java.util.concurrent.ExecutorService;
   
2. import java.util.concurrent.Executors;
   
3. import java.util.concurrent.locks.Lock;
   
4. import java.util.concurrent.locks.ReentrantLock;
   
5. 
   
6. public class ThreadPoolTest {
   
7.         
   
8.         public static void main(String[] args) {
   
9.                
   
10.                 ExecutorService es = Executors.newFixedThreadPool(3);
    
11.                 Num n = new Num();
    
12.                 while(n.get()>0){                        
    
13.                         es.execute(n);
    
14.                 }
    
15.                
    
16.                 es.shutdown();               
    
17.         }
    
18. }
    
19. 
    
20. class Num implements Runnable{
    
21. 
    
22.         private int ticket = 100;
    
23.         
    
24.         public int get(){
    
25.                 return ticket;
    
26.         }
    
27.         Lock lock = new ReentrantLock();
    
28.         
    
29.         @Override
    
30.         public void run() {
    
31.                 lock.lock();
    
32.                 try {
    
33.                         if(ticket>0){
    
34.                         ticket--;
    
35.                         Thread.sleep(50);
    
36.                         System.out.println(Thread.currentThread().getName() + "卖掉" + (ticket+1) + "号票");
    
37.                 }
    
38.                         
    
39.                 } catch (InterruptedException e) {
    
40.                         e.printStackTrace();
    
41.                 } finally {
    
42.                         lock.unlock();
    
43.                 }
    
44. 
    
45.                
    
46.         }
    
47.         
    
48. }

复制代码

这段代码运行中会停止，有时候会报异常，把线程创建改成传统方式就没问题。可能是线程池的问题，但是不知道具体什么问题。求真相。

1. import java.util.concurrent.ExecutorService;
   
2. import java.util.concurrent.Executors;
   
3. import java.util.concurrent.locks.Lock;
   
4. import java.util.concurrent.locks.ReentrantLock;
   
5. 
   
6. public class ThreadPoolTest {
   
7.         
   
8.         public static void main(String[] args) {
   
9.                
   
10.                 ExecutorService es = Executors.newFixedThreadPool(3);
    
11.                 Num n = new Num();
    
12.                 while(n.get()>0){                        
    
13.                         es.execute(n);
    
14.                 }
    
15.                
    
16.                 es.shutdown();               
    
17.         }
    
18. }
    
19. 
    
20. class Num implements Runnable{
    
21. 
    
22.         private int ticket = 100;
    
23.         
    
24.         public int get(){
    
25.                 return ticket;
    
26.         }
    
27.         Lock lock = new ReentrantLock();
    
28.         
    
29.         @Override
    
30.         public void run() {
    
31.                 lock.lock();
    
32.                 try {
    
33.                         if(ticket>0){
    
34.                         ticket--;
    
35.                         Thread.sleep(50);
    
36.                         System.out.println(Thread.currentThread().getName() + "卖掉" + (ticket+1) + "号票");
    
37.                 }
    
38.                         
    
39.                 } catch (InterruptedException e) {
    
40.                         e.printStackTrace();
    
41.                 } finally {
    
42.                         lock.unlock();
    
43.                 }
    
44. 
    
45.                
    
46.         }
    
47.         
    
48. }

复制代码