栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

面试中遇到的多线程笔试题

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

面试中遇到的多线程笔试题

面试官出了一道笔试题,自己感觉还不错,就记录下来了。 题目

1、有20个账户,每个账户初始10000元。
2、有10个转账线程,从20个账户中随机抽取2个进行转账,转账金额为100以内随机的正整数。
3、每个线程转账100次。
4、请打印转账结束后所有账户的金额。

解决思路

我的解决思路是用juc下的CopyOnWriteArrayList,存储每个账户,账户的金额用AtomicInteger赋值,保证原子性。再自定义个简单线程池(阻塞队列参数用的是LinkedBlockingQueue,要设置队列大小,默认值是Integer.MAX_VALUE,可能会堆积大量的请求,从而导致 OOM),10个转账线程转账100次,每次随机获取两个账户时,要注意随机获取的账户是否是同一个。转账完成后,打印即可。

代码演示
import java.util.ArrayList;
import java.util.Random;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.locks.ReentrantReadWriteLock;



class zhCache{
    CopyOnWriteArrayList list = new CopyOnWriteArrayList<>(new ArrayList<>(20));

    public AtomicInteger setNumber(){
        AtomicInteger atomicInteger = new AtomicInteger(10000);
        return atomicInteger;
    }

}

public class ThreadStudyDemo {
    public static void main(String[] args) {
        //初始化CountDownLatch 计数器的值
        final CountDownLatch countDownLatch = new CountDownLatch(10);

        zhCache zhCache = new zhCache();
        for(int i=0;i<20;i++){
            zhCache.list.add(zhCache.setNumber());
        }
        System.out.println(zhCache.list);

        //自定义简单线程池,设置最多放10个线程
        ExecutorService threadPool=new ThreadPoolExecutor(
                5,
                10,
                2L,
                TimeUnit.SECONDS,
                new LinkedBlockingQueue<>(5),
                Executors.defaultThreadFactory(),
                new ThreadPoolExecutor.CallerRunsPolicy()//如果线程满了,教给主线程执行
        );

        try {
            for (int j = 1; j <= 10; j++) {
                threadPool.execute(()->{
                    System.out.println(Thread.currentThread().getName()+"开始执行任务");
                    for(int i=1;i<=100;i++){
                        int m1 = new Random().nextInt(20);
                        int m2 = new Random().nextInt(20);
                        //防止获取的是同一个账户
                        while (m1==m2){
                            m2=new Random().nextInt(20);
                        }

                        AtomicInteger atomicInteger1 = zhCache.list.get(m1);
                        AtomicInteger atomicInteger2 = zhCache.list.get(m2);
                        int n1 = new Random().nextInt(99) + 1;

                        atomicInteger1.addAndGet(n1);
                        atomicInteger2.addAndGet(-n1);
                    }
                    countDownLatch.countDown();
                });
            }

        }catch (Exception e){
            e.printStackTrace();
        }finally {
            threadPool.shutdown();
        }

        try {
//            System.out.println(Thread.currentThread().getName()+"睡5秒");
//            TimeUnit.SECONDS.sleep(5);
            countDownLatch.await();

        }catch (Exception e){
            e.printStackTrace();
        }

        int count=0;
        for (int i = 0; i < 20; i++) {
            AtomicInteger atomicInteger = zhCache.list.get(i);
            System.out.println("第"+(i+1)+"个账户金额为:"+atomicInteger);
            count=atomicInteger.addAndGet(count);
        }
        System.out.println();
        System.out.println("20个账户总金额为:"+count);

    }

}
运行结果


这只是提供一下自己的思路和解决办法,有什么没考虑到位或者有问题的地方,欢迎大家指正,谢谢!也欢迎大家说出看法,提供自己解题思路,互相学习。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/926514.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号