阅读背景:

两个线程交替打印1~26和a~z

来源:互联网 

方法1:lock + Condition

package com.example.springboot.demo.juc;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class Test1 {

    //volatile 保证isNum线程间可见
    private static volatile boolean isNum = true;

    private Lock lock = new ReentrantLock();
    private Condition num = lock.newCondition();
    private Condition cha = lock.newCondition();

    public void printNum(int[] nums){
        try {
            lock.lock();
            for (int i = 0; i < nums.length;i++) {
                while (isNum) {
                    System.out.print(nums[i]);
                    isNum = false;
                }
                TimeUnit.MILLISECONDS.sleep(300);
                cha.signalAll();    //通知打印字母线程
                num.await();        //打印数字线程等待
            }

        } catch (InterruptedException e) {
            e.printStackTrace();
        }finally {
            lock.unlock();
        }
    }


    public void printCha(char[] letters){
        try {
            lock.lock();
            for (int i = 0; i < letters.length;i++) {
                char letter = letters[i];
                while (!isNum) {
                    System.out.print(letter);
                    isNum = true;
                }
                TimeUnit.MILLISECONDS.sleep(300);
                num.signalAll();  //通知打印数字线程
                cha.await();      //打印字母线程等待
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }finally {
            lock.unlock();
        }
    }


    public static void main(String[] args) {

        Test1 test1 = new Test1();

        int[] nums = new int[26];
        for(int i = 0 ; i<26;i++){
            nums[i] = i+1;
        }
        char[] letters = new char[26];
        for(int i = 0 ;i < 26;i++){
            letters[i] = (char)('a'+i);
        }

        new Thread(()->{
            test1.printNum(nums);
        }).start();

        new Thread(()->{
            test1.printCha(letters);
        }).start();


    }
}
package com.ex



你的当前访问异常,请进行认证后继续阅读剩余内容。

分享到: