JAVA测试之使用lock方法达成线程安全------JAVA

青旅半醒 2024-03-22 12:38 3阅读 0赞

>     import java.util.concurrent.locks.ReentrantLock;
>     
>     public class LockTest
>     {
>         public static void main(String[] args)
>         {
>             Windows w = new Windows();
>             Windows w1 = new Windows();
>             Windows w2 = new Windows();
>             w.setName("窗口一");
>             w1.setName("窗口二");
>             w2.setName("窗口三");
>             w.start();
>             w1.start();
>             w2.start();
>         }
>     }
>     
>     class Windows extends Thread
>     {
>         //执行lock方法
>         static int ticket = 100;
>         private static final ReentrantLock lock = new ReentrantLock();
>         public void run()
>         {
>             while(true)
>             {
>                 lock.lock();
>                 try
>                 {
>                     if (ticket > 0) {
>                         try {
>                             Thread.sleep(100);
>                         } catch (InterruptedException e) {
>                             throw new RuntimeException(e);
>                         }
>                         System.out.println(Thread.currentThread().getName() + ticket);
>                         ticket--;
>                     } else {
>                         break;
>                     }
>                 }
>                 finally
>                 {
>                     lock.unlock();
>                 }
>     
>             }
>         }
>     }
> 
> import java.util.concurrent.locks.ReentrantLock;
> 
> public class LockTest  
> \{  
> public static void main(String\[\] args)  
> \{  
> Windows w = new Windows();  
> Windows w1 = new Windows();  
> Windows w2 = new Windows();  
> w.setName("窗口一");  
> w1.setName("窗口二");  
> w2.setName("窗口三");  
> w.start();  
> w1.start();  
> w2.start();  
> \}  
> \}
> 
> class Windows extends Thread  
> \{  
> //执行lock方法  
> static int ticket = 100;  
> private static final ReentrantLock lock = new ReentrantLock();  
> public void run()  
> \{  
> while(true)  
> \{  
> lock.lock();  
> try  
> \{  
> if (ticket > 0) \{  
> try \{  
> Thread.sleep(100);  
> \} catch (InterruptedException e) \{  
> throw new RuntimeException(e);  
> \}  
> System.out.println(Thread.currentThread().getName() + ticket);  
> ticket--;  
> \} else \{  
> break;  
> \}  
> \}  
> finally  
> \{  
> lock.unlock();  
> \}
> 
> \}  
> \}  
> \}