多线程循环打印数组 -- Java笔记

时间:2022-07-26
本文章向大家介绍多线程循环打印数组 -- Java笔记,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。

问题描述:

现有多个长度相同的数组,现要求使用多线程将数组内的数交替打印。

如:

int[] ai = {1,2,3,4,5,6,7};
String[] ac = {"A","B","C","D","E","F","G"};
最终打印出 : 1A2B3C4D5E6F7G。

实现方法(1)

1.使用 import java.util.concurrent.locks.LockSupport;

2.park方法和unpark方法。

代码分析:
import java.util.concurrent.locks.LockSupport;

public class T3 {
    static Thread t1=null,t2=null,t3=null;
    public static void main(String[] args) throws Exception {
        int[] ao = {1,2,3,4,5,6};
        String[] ab = {"A","B","C","D","E","F"};
        boolean[] ac = {true,false,true,false,true,false};

        t1 = new Thread(()->{
            for (String a:ab) {
                System.out.print(a+" ");
                LockSupport.unpark(t2);
                LockSupport.park();
            }
        },"t1");

        t2 = new Thread(()->{
            for (int b:ao) {
                LockSupport.park();
                System.out.print(b+" ");
                LockSupport.unpark(t3);
            }
        },"t2");

        t3 = new Thread(()->{
            for (boolean c:ac) {
                LockSupport.park();
                System.out.print(c+" || ");
                LockSupport.unpark(t1);
            }
        },"t3");

        t1.start();
        t2.start();
        t3.start();
    }
}

如上代码:

1.程序中,我定义了3个长度相同但类型不同的数组,因此开了三个线程 t1 , t2 , t3 。

2.三个线程同时使用start()方法;

3.其中,线程t1首先打印数组中的第一个数字,同时释放t2线程(unpark(t2)),阻塞自己(park(t1))。

4.t2线程释放,打印数组中的数字后释放t3,如此循环往复。

5.得出如下结论。

实现方法(2)

1. notify() + wait() 方法。

2. CountDownLatch 门栓机制()

private static CountDownLatch latch = new CountDownLatch(1);

可理解为我们平时门上的插销,参数为门栓的数量。目的是确定线程开始的顺序。

代码分析:
import java.util.concurrent.CountDownLatch;

public class Cycle {
    private static CountDownLatch latch = new CountDownLatch(1);
    public static void main(String[] args) throws Exception{
        final Object s = new Object();
        int[] ai = {1,2,3,4,5,6,7};
        String[] ac = {"A","B","C","D","E","F","G"};

        new Thread(()->{
                    try {
                        latch.await();
                    }
                    catch (InterruptedException e)
                    {
                        e.printStackTrace();
                    }
                    synchronized (s){
                        for (int a:ai) {
                            System.out.print(a);
                            try {
                                s.notify();
                                s.wait();
                            }catch (InterruptedException e)
                            {
                                e.printStackTrace();
                            }
                        }
                        s.notify();
                    }

                },"t1"
        ).start();

        new Thread(
                ()->{
                    synchronized (s){
                        for (String b:ac) {
                            System.out.print(b);
                            latch.countDown();
                            try {
                                s.notify();
                                s.wait();
                            }catch (InterruptedException e)
                            {
                                e.printStackTrace();
                            }
                        }
                        s.notify();
                    }

                },"t2"
        ).start();
    }
}

1. 这里我们定义了一个门栓,一个锁,两个数组。

2. 同时start()两个线程。由于我在线程t1中上了门栓,且开门栓的方法在第二个线程中,因此,这就保证了第二个线程先开始。

3. t2先打印完,t1解锁.notify(),t2等待.wait()。如此循环往复。

4. 得出如下结论。

注:本篇文章来自于B站教学视频中的一点小小笔记,由于本人一直从事于C#工作,Java接触较少,上述文章中若有错误,还望纠正。