1. 程式人生 > 程式設計 >java實現多執行緒交替列印

java實現多執行緒交替列印

本文例項為大家分享了java實現多執行緒交替列印的具體程式碼,供大家參考,具體內容如下

notify+wait實現

import org.junit.Test;
import java.util.concurrent.*;

public class TestThreadLocal {
 Object o = new Object();
 CountDownLatch c=new CountDownLatch(2);
 @Test
 public void vvvvvvvv() throws InterruptedException {
  Thread t1 = new Thread() {
   @Override
   public void run() {
    for (int i = 0; i < 26; i++) {
     synchronized (o) {
      System.out.print((char) (65 + i));
      o.notify();
      try {
       if(i<25)o.wait();
      } catch (InterruptedException e) {
       e.printStackTrace();
      }
     }
    }
    c.countDown();
   }
  };
  Thread t2 = new Thread() {
   @Override
   public void run() {
    for (int i = 0; i < 26; i++) {
     synchronized (o) {
      System.out.print(1 + i);
      o.notify();
      try {
       if(i<25)o.wait();
      } catch (InterruptedException e) {
       e.printStackTrace();
      }
     }
    }
    c.countDown();
   }
  };
  t1.start();
  t2.start();
  //t1.join();
  //t2.join();
  c.await();
 }
}

A1B2C3D4E5F6G7H8I9J10K11L12M13N14O15P16Q17R18S19T20U21V22W23X24Y25Z26
t2可能先執行,notify(只隨機喚醒一個 wait 執行緒)改成notifyAll(喚醒所有 wait 執行緒)更好。
這兩個方法只喚醒,被喚醒的執行緒處於runnable狀態。想交替執行,需要負責喚醒的執行緒自己阻塞。

LockSupport實現

import org.junit.Test;
import java.util.concurrent.*;
import java.util.concurrent.locks.LockSupport;

public class TestThreadLocal {
 CountDownLatch c=new CountDownLatch(2);
 Thread t1,t2;
 @Test
 public void vvvvvvvv() throws InterruptedException {
  t1 = new Thread() {
   @Override
   public void run() {
    for (int i = 0; i < 26; i++) {
     System.out.print((char) (65 + i));
     LockSupport.unpark(t2);
     LockSupport.park();
    }
    c.countDown();
   }
  };
  t2 = new Thread() {
   @Override
   public void run() {
    for (int i = 0; i < 26; i++) {
     LockSupport.park();
     System.out.print(1+i);
     LockSupport.unpark(t1);
    }
    c.countDown();
   }
  };
  t1.start();
  t2.start();
  //t1.join();
  //t2.join();
  c.await();
 }
}

unpark呼叫時,如果當前執行緒還未進入park,則許可為true;
park呼叫時,判斷許可是否為true,如果是true,則繼續往下執行;如果是false,則等待,直到許可為true。
如果t2先執行,會park讓t1先執行。如果t1先執行,列印後unpark t2,保證兩個執行緒不會同時阻塞。
如果t2的LockSupport.park()和System.out.print(1+i)交換位置,可能出現t2連續列印兩次的情況。
即t1列印後,執行unpartk(t2)前t2列印一次,然後t1 unpark t2後t2搶在t1前再列印一次。

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。