多线程在Java项目中的使用案例(笔记)

1. 实现runnable接口

@Override
    public Boolean addMeetingExpertIds(MeetAddExpertDto meetAddExpertDto, Long userId) {
        // 会议关联到专家
        // 如果需要发给专家
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    if (meetAddExpertDto.getExpertIdList().size() > 0) {
                        // 准备通知数据
                        List<AddMeeTempDto> addMeeTempDtoList = new ArrayList<>();
                        for (Long expertId : meetAddExpertDto.getExpertIdList()) {
                            AddMeeTempDto addMeeTempDto = new AddMeeTempDto()
                                    .setExpertId(expertId)
                                    .setTemplateDetail(meetAddExpertDto.getTemplate() + expertId);
                            addMeeTempDtoList.add(addMeeTempDto);
                        }
                        expertMeetingService.addExpertMeetingBatch(meetAddExpertDto.getMeetingId(), addMeeTempDtoList, userId);
                        Thread.sleep(300);
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    log.info("线程结束");
                }
            }
        }).start();
        return true;
    }

Lambda写法

@Override
    public void test(Integer meetId) {

        new Thread(() -> {
            try {
                for (int i = 0; i < 10; i++) {
                    log.info("线程" + meetId + "正在输出" + i);//逻辑代码
                    if (i == 5) {
                        Thread.sleep(200);
                        log.info("线程" + meetId + "睡眠");
                    }
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                log.info("线程结束");
            }
        }).start();
    }

2. 创建线程池

@Override
    public void test(Integer meetId) {
        //创建一个具有10个线程的线程池
        ExecutorService threadPool = Executors.newFixedThreadPool(10);
        long threadpoolUseTime = System.currentTimeMillis();
        threadPool.execute(new Runnable() {
            @Override
            public void run() {
                try {
                    for (int i = 0; i < 10; i++) {
                        log.info("线程" + meetId + "正在输出" + i);
                        if (i == 5) {
                            Thread.sleep(200);
                            log.info("线程" + meetId + "睡眠");
                        }
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });
        long threadpoolUseTime1 = System.currentTimeMillis();
        System.out.println("多线程用时"+(threadpoolUseTime1-threadpoolUseTime));
        //销毁线程池
        threadPool.shutdown();
    }

Lambda写法

@Override
    public void test(Integer meetId) {
        //创建一个具有10个线程的线程池
        ExecutorService threadPool = Executors.newFixedThreadPool(10);
        long threadpoolUseTime = System.currentTimeMillis();
        threadPool.execute(new Runnable() {
            @Override
            public void run() {
                try {
                    for (int i = 0; i < 10; i++) {
                        log.info("线程" + meetId + "正在输出" + i);
                        if (i == 5) {
                            Thread.sleep(200);
                            log.info("线程" + meetId + "睡眠");
                        }
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });
        long threadpoolUseTime1 = System.currentTimeMillis();
        System.out.println("多线程用时"+(threadpoolUseTime1-threadpoolUseTime));
        //销毁线程池
        threadPool.shutdown();
    }

业务需求
电影院新片首映，观影人数大量增加，为提高日营业额，线下售票窗口由原单窗口调整为3窗口，设计一段简单的程序模拟该售票过程。
程序设计
多线程场景下需考虑线程安全的问题，避免多个线程争抢同一个资源导致业务逻辑出现错误。实现线程安全的方式有很多，这里使用Java Lock 接口中的方法实现。
代码示例

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

/**
 * 测试类
 */
public class DemoTest {
    public static void main(String[] args) {

        //窗口01
        new Thread(() -> {
            while (true) {
                //获取当前票余量
                int currentTickets = TicketSource.getCurrentTickets();
                if (currentTickets > 0) {
                    TicketSource.saleTickets();
                    waitProcess();
                } else {
                    stopSale();
                    break;
                }
            }
        }, "01").start();

        //窗口02
        new Thread(() -> {
            while (true) {
                int currentTickets = TicketSource.getCurrentTickets();
                if (currentTickets > 0) {
                    TicketSource.saleTickets();
                    waitProcess();
                } else {
                    stopSale();
                    break;
                }
            }
        }, "02").start();

        //窗口03
        new Thread(() -> {
            while (true) {
                int currentTickets = TicketSource.getCurrentTickets();
                if (currentTickets > 0) {
                    TicketSource.saleTickets();
                    waitProcess();
                } else {
                    stopSale();
                    break;
                }
            }
        }, "03").start();


    }

    //模拟售票员卖出一张票用时且假设每个售票员业务能力相同
    private static void waitProcess() {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    //停止售卖
    private static void stopSale() {
        System.out.println(Thread.currentThread().getName() + "窗口：今日票已卖完！");
    }
}

/**
 * 电影票资源类
 */
class TicketSource {

    //当前电影票余量
    private static int currentTickets = 30;

    //加锁确保多线程场景下的线程安全
    private static Lock lock = new ReentrantLock();

    /**
     * 卖票
     *
     * @return 当前电影票余量
     */
    public static void saleTickets() {
        lock.lock();
        try {
            if (currentTickets > 0) {
                //模拟卖票
                currentTickets--;

                System.out.println(
                        Thread.currentThread().getName() + "窗口出票成功！"
                                + "当前票余量：" + currentTickets);
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }
    }

    public static int getCurrentTickets() {
        return currentTickets;
    }
}

运行结果

D:\installPath\Java\jdk1.8.0_121\bin\java.exe "-javaagent:D:\installPath\IntelliJ IDEA 2019.1.4\lib\idea_rt.jar=64339:D:\installPath\IntelliJ IDEA 2019.1.4\bin"
03窗口出票成功！当前票余量：29
02窗口出票成功！当前票余量：28
01窗口出票成功！当前票余量：27
03窗口出票成功！当前票余量：26
01窗口出票成功！当前票余量：25
02窗口出票成功！当前票余量：24
03窗口出票成功！当前票余量：23
02窗口出票成功！当前票余量：22
01窗口出票成功！当前票余量：21
01窗口出票成功！当前票余量：20
02窗口出票成功！当前票余量：19
03窗口出票成功！当前票余量：18
03窗口出票成功！当前票余量：17
01窗口出票成功！当前票余量：16
02窗口出票成功！当前票余量：15
03窗口出票成功！当前票余量：14
02窗口出票成功！当前票余量：13
01窗口出票成功！当前票余量：12
03窗口出票成功！当前票余量：11
02窗口出票成功！当前票余量：10
01窗口出票成功！当前票余量：9
01窗口出票成功！当前票余量：8
02窗口出票成功！当前票余量：7
03窗口出票成功！当前票余量：6
03窗口出票成功！当前票余量：5
02窗口出票成功！当前票余量：4
01窗口出票成功！当前票余量：3
02窗口出票成功！当前票余量：2
01窗口出票成功！当前票余量：1
03窗口出票成功！当前票余量：0
03窗口：今日票已卖完！
01窗口：今日票已卖完！
02窗口：今日票已卖完！

Process finished with exit code 0