线程通信方式：condition+lock实现线程之间的通信方式

小灰灰 2024-04-19 15:52 156阅读 0赞 
  1. /*
  2.  * 线程质之间的通信方式二：condition+lock实现线程之间的通信方式
  3.  * */
  4. public class ThreadCommunication2 {
  6.     private int i = 0;
  8.     /*重入锁：参数： true 代表公平锁 ，false：独占锁*/
  9.     private Lock lock = new ReentrantLock(false);
  11.     private Condition condition = lock.newCondition();
  13.     /*奇数*/
  14.     public void odd() {
  15.         while (i < 10) {
  16.             try {
  17.                 lock.lock();
  18.                 if (i % 2 == 1) {
  19.                     /*唤醒该线程*/
  20.                     condition.signal();
  21.                     System.out.println("奇数：" + i+","+Thread.currentThread().getName());
  22.                     i++;
  23.                 } else {
  24.                     try {
  25.                         /*该线程等待*/
  26.                         condition.await();
  27.                     } catch (InterruptedException e) {
  28.                         e.printStackTrace();
  29.                     }
  30.                 }
  31.             } finally {
  32.                 lock.unlock();
  33.             }
  34.         }
  35.     }
  37.     /*偶数*/
  38.     public void even() {
  39.         while (i < 10) {
  40.             lock.lock();
  41.             try {
  42.                 if (i % 2 == 0) {
  43.                     System.out.println("偶数：" + i +","+Thread.currentThread().getName());
  44.                     i++;
  45.                     /*唤醒该线程*/
  46.                     condition.signal();
  47.                 } else {
  48.                     try {
  49.                         /*该线程等待*/
  50.                         condition.await();
  51.                     } catch (InterruptedException e) {
  52.                         e.printStackTrace();
  53.                     }
  54.                 }
  55.             } finally {
  56.                 lock.unlock();
  57.             }
  59.         }
  60.     }
  62.     public static void main(String[] args) {
  63.         ThreadCommunication2 threadCommunication = new ThreadCommunication2();
  64.         Thread thread1 = new Thread("thread1") {
  65.             @Override
  66.             public void run() {
  67.                 threadCommunication.odd();
  68.             }
  69.         };
  70.         Thread thread2 = new Thread("thread2") {
  71.             @Override
  72.             public void run() {
  73.                 threadCommunication.even();
  74.             }
  75.         };
  77.         thread1.start();
  78.         thread2.start();
  79.     }
  80. }

运行结果：

  1. 偶数：0,thread2
  2. 奇数：1,thread1
  3. 偶数：2,thread2
  4. 奇数：3,thread1
  5. 偶数：4,thread2
  6. 奇数：5,thread1
  7. 偶数：6,thread2
  8. 奇数：7,thread1
  9. 偶数：8,thread2
  10. 奇数：9,thread1

发表评论

表情：
评论列表 （有 0 条评论，156人围观）

还没有评论，来说两句吧...

相关阅读