多线程应用案例

需求

解析一个Excel中多个sheet的数据,那么此时就可以考虑使用多线程,每个线程解析一个sheet中的数据,然后等待所有的sheet数据解析完成后,再把数据入库

在这个需求中,要实现主线程等待所有现场完成shee数据解析操作,

第一种方案:采用join()方法

public class MyJoinTest {
public static void main(String[] args) throws InterruptedException {
        System.out.println("开始解析数据");
        Thread thread1 = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("解析sheet1 的数据");
            }
        });
        Thread thread2 = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("解析sheet2 的数据");
            }
        });
        thread1.start();
        thread2.start();
        thread1.join();
        thread2.join();
        System.out.println("入库");
        System.out.println("完成");
    }
}

执行结果:


看一下Thread的join方法

public final void join() throws InterruptedException {
    join(0);
}


死循环检查join线程是否活着,如果join线程活着则让当前线程永远等待,其中wait(0);表示永远等下去。直到join线程终止后,线程的this,notifyAll()方法会被调用,调用this.notifyAll方法是在JVM里面实现的。只有再JVM源码里能看见。

在JDK1.5后的并发包下提供了CountDownLatch也可以实现join的功能,并且比join的功能更多,

第二种方案:CountDownLatch

代码如下:

public class MyCountDownLatch {
static CountDownLatch count = new CountDownLatch(2);
    public static void main(String[] args) throws InterruptedException {
new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("解析sheet1 的数据");
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                count.countDown();
            }
        }).start();
        new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("解析sheet2 的数据");
                count.countDown();
            }
        }).start();
        count.await();
        System.out.println("入库");
        System.out.println("完成");
    }
}

执行结果


CountDownLatch的构造函数接收一个Int类型的参数作为计数器,如果你想等待n个点完菜,这里就传n。

当我们调用CountDownLatch的countDown()方法时候n就减1即就是n=n-1。CountDownLatch的await方法会阻塞当前线程,知道n=0,由于countDown()方法可以再任何地方使用,所以这里的n个点,可以是n个线程,也可以是一个线程里的n个执行步骤。用在多线程时,只需要把这个CountDownLatch的引用传递到线程里即可。

注:

计数器必须大于0,计数器等于0的时候,调用await方法是不会阻塞当前线程,CountDownLatch不可能重新初始化或者修改CountDownLatch对象的内部计数器的值,一个线程调用countDown方法happen-before,另外已发个线程调用await方法。


上一篇:CountDownLatch用例、源码分析讲解


下一篇:CountDownLatch工具类使用