java 并发完成任务之CountDownLatch

import java.util.Random;
import java.util.concurrent.CountDownLatch;

public class App {

    public static void main(String[] args) throws InterruptedException {
        CountDownLatch latch=new CountDownLatch(2);
        Work worl = new Work(latch)  ;
        Work wor2 = new Work(latch)  ;
        worl.start();
        wor2.start();
        latch.await();

        CustomerInfo customerInfo=new CustomerInfo();
        customerInfo.setConsumeSum((int)worl.getResult());
        customerInfo.setSortInAllCustomer((int)wor2.getResult());
        System.out.println(customerInfo);
    }
}

class CustomerInfo
{
    private int sortInAllCustomer;
    private int consumeSum;

    public int getSortInAllCustomer() {
        return sortInAllCustomer;
    }

    public void setSortInAllCustomer(int sortInAllCustomer) {
        this.sortInAllCustomer = sortInAllCustomer;
    }

    public int getConsumeSum() {
        return consumeSum;
    }

    public void setConsumeSum(int consumeSum) {
        this.consumeSum = consumeSum;
    }

    @Override
    public String toString()
    {
        return String.format("当前客户消费%d,在所有用户中排名第%d",getConsumeSum(),getSortInAllCustomer());
    }

}

class Work extends Thread
{
    private CountDownLatch latch;
    private Object result;

    public Work(CountDownLatch latch)
    {
        this.latch=latch;
    }

    @Override
    public void run() {
        try {
            Random random=new Random();
            int ms = random.nextInt(10)+1;
            Thread.sleep(1000*ms);
            this.result=ms;
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        finally {
            latch.countDown();
        }
    }

    public Object getResult() {
        return result;
    }
}