微信公众号 讲师中心
首页
文章
后端开发 web前端 数据库 开发工具 php框架 常见问题 科技 Java 系统教程 电脑教程 硬件教程 手机教程 软件教程 游戏教程 自媒体 新闻
专题
后端开发 web前端 数据库 开发工具 php框架 科技 Java 系统教程 电脑教程 硬件教程 手机教程 软件教程 游戏教程 新闻
AI工具
AI 聊天问答 Agent智能体 AI 文本写作 AI 绘画作图 AI 设计工具 AI 视频创作 AI 音频制作 AI 办公学习 AI 编程开发 Prompt指令
学习
大前端 后端开发 数据库 移动端 运维开发 计算机基础
编程手册
大前端 后端开发 数据库 移动端 运维开发 计算机基础
下载
js特效 网站源码 工具下载 类库下载 网站素材 学习资源 插件扩展 手机/移动开发 手机游戏
最近更新
搜索
后端开发 web前端 数据库 开发工具 php框架 常见问题 科技 Java 系统教程 电脑教程 硬件教程 手机教程 软件教程 游戏教程
自媒体 新闻
java-ee - JAVA的异步线程与同步线程问题.
PHP中文网
PHP中文网 2017-04-18 09:26:05
[Java讨论组]
0 2 383
举报 
    public static void main(String[] args) {
        int threadCount = 1000; // 线程数量(1000)
        CountDownLatch countDownLatch = new CountDownLatch(threadCount);
        List list = new ArrayList();
        
        MyThreadTest myThreadTest = new MyThreadTest(list);
       
        MySync mySync = MySync.getMySync(myThreadTest,countDownLatch);
        // mySync = new MySync(myThreadTest,countDownLatch);  // 为什么放开这段代码,会连 System.out.println("========:"+list.size()); 都不会执行了?
        
        try {
        for(int i =0;i list;
    
    private int i = 0;
    
    public MyThreadTest(List list){
        this.list = list;
    }
    
    @Override
    public void run() {
        i++;
        list.add(new Object());
        System.out.println(i);
    }
}

class MySync{

    private static CountDownLatch countDownLatch;
    private static Runnable runn;
    
    public MySync(){}
    
    @SuppressWarnings("static-access")
       public MySync(Runnable runn,CountDownLatch countDownLatch){
        Enhancer enhancer = new Enhancer();
        enhancer.setSuperclass(MySync.class);
        enhancer.setCallback(new MethodInterceptorImpl());

        MySync mySync = (MySync)enhancer.create();
        mySync.countDownLatch = countDownLatch;
        mySync.runn = runn;
    }
    
    @SuppressWarnings("static-access")
    public static MySync getMySync(Runnable runn,CountDownLatch countDownLatch){
         Enhancer enhancer = new Enhancer();
         enhancer.setSuperclass(MySync.class);
         enhancer.setCallback(new MethodInterceptorImpl());
         
         MySync mySync = (MySync)enhancer.create();
         mySync.countDownLatch = countDownLatch;
         mySync.runn = runn;
         return mySync;
    }
    
    public void run() throws InterruptedException {
            MyThreadPool.execute(runn);
    }
    
    private static class MethodInterceptorImpl implements MethodInterceptor{

        @Override
        public Object intercept(Object obj, Method method, Object[] args, MethodProxy proxy) throws Throwable {
            Object result = proxy.invokeSuper(obj, args);
            if("public void MySync.run() throws java.lang.InterruptedException".equals(method.toString())){
                countDownLatch.countDown(); // 完成一个子线程,减少一个计数
                return result;
            }
            return result;
        }
        
    }
}

class MyThreadPool {

    private static ExecutorService pool = null;
    
    @SuppressWarnings("unchecked")
    public static  T submit(Runnable runn){
        T result = null;
        if (pool == null) {
            pool = Executors.newCachedThreadPool();
        }
        try {
            Future future = pool.submit(runn);
            if(future.isDone()==true){
                result = (T) future.get();
            }
            return result;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return result;
    }
    
    public static void execute(Runnable runn){
        if (pool == null) {
            pool = Executors.newCachedThreadPool();
        }
        try {
            pool.execute(runn);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}


System.out.println("========:"+list.size()); 使用计数来进行了同步,这段代码不应该是最后才会输出的吗?测试结果是不确定什么时候输出.
如果放开注释的那段代码,为什么连System.out.println("========:"+list.size()); 都不输出了?这是什么原因造成的?(不知道这段代码还有什么BUG,请各位大神指导)


                            
                                    
            
            
            
            
            
            
            
            
            
            
            
            
            
            

            

                

                    PHP中文网
                    

                        PHP中文网
                        
认证0级讲师

                    

                

                

                    

                    

                        

                            
                        

                    

                

            

            

                

                    
全部回复(2)

                    
                

                


                                

                    黄舟
                    

                        

                            

                                黄舟2017-04-18 09:28:05
                                2楼
                            

                            
先回答楼主的问题


    

  1. CGLIB 字节码增强是对的你MySync的方法进行增强,你文中的步骤是先执行MySync.run(),然后再把线程丢入线程池,所以在执行MySync.run()的时候就已经执行countDownLatch.countDown()了,所以这里会出现一个情况是,countDownLatch.await()的时候线程池里面还有茫茫多的线程在运行,所以list的size是随机的
    2. 

  2. 你直接放开mySync = new MySync(myThreadTest,countDownLatch)这段代码以后,构造器直接构造MySync是没有经过CGLIB加强的类,MySync mySync = (MySync) enhancer.create();mySync.countDownLatch = countDownLatch;mySync.runn = runn;你在构造器里面增强的这个MySync,随着构造方法的结束,就被垃圾回收器回收了
    3. 



再来说说楼主程序的问题


    

  1. if("public void MySync.run() throws java.lang.InterruptedException".equals(method.toString())这一段代码,可以用method.getName()来比较
    2. 

  2. MyThreadTest这个线程类,在run()中执行i++不是线程安全的,并且因为list也不是先后才能安全的,所以list.add()也会出现线程竞争问题
    3. 


                            

                                 
                                赞 +0
                                

                                    添加回复
                                

                            

                                                            
                            
                            

                                
    
                                    
                                


                            



                        

                    


                

                

                                

                    PHP中文网
                    

                        

                            

                                PHP中文网2017-04-18 09:28:05
                                1楼
                            

                            
首先，我想吐槽一下，代码确实很乱，看了老半天。


总结一下，你这里主要使用的是 CountDownLatch 和 CGLIB 字节码增强技术。


CountDownLatch 的主要功能是它允许一个或多个线程一直等待，直到其他线程的操作执行完后再执行。但是因为每个线程在执行完要在 finally 块调用 countdown() 方法，所以想利用 CGLIB 在线程执行完之后，自动调用 coundown()方法。但问题也就出现在这里：


public Object intercept(Object obj, Method method, Object[] args, MethodProxy proxy) throws Throwable {
    Object result = proxy.invokeSuper(obj, args); // 这里实际上是非阻塞的。
    if("public void MySync.run() throws java.lang.InterruptedException".equals(method.toString())){
        countDownLatch.countDown(); // 完成一个子线程,减少一个计数
        return result;
    }
    return result;
}

                            

                                 
                                赞 +0
                                

                                    添加回复
                                

                            

                                                            
                            
                            

                                
    
                                    
                                


                            



                        

                    


                

                

                



                

            

        

        
        

            
            

                

                    
专题推荐

                    更多>
                    
                

                


                    
                


            

            


                

                    
 热门话题 

                    
                

                

                    
                

            

            

                

                    
热门教程

                    更多>
                    
                

                

                    

                        
相关教程 

                        
热门推荐

                        
最新课程

                    

                    
    
                                            

                    
                    
                

                
            

            

                

                    
最新下载

                    更多>
                    
                


                                

                

                    

                        
网站特效 

                        
网站源码

                        
网站素材

                        
前端模板

                    

                    

                    

                    

                    

                

                
            


        

    







    

        

            

                

                    

                        关于我们
                        免责申明
                        举报中心
                        意见反馈
                        讲师合作
                        广告合作
                        
                        最新更新
                        English
                                                

                    

                    
php中文网：公益在线php培训，帮助PHP学习者快速成长！

                    

                      
                        关注服务号
                        
                      
                        
                        技术交流群
                        
                      
                        

                    

                

                
            

            

                

                    
                    

                        
PHP中文网订阅号

                        
每天精选资源文章推送

                    

                

                

                    
                    

                        
PHP中文网APP

                        
随时随地碎片化学习

                    

                

            

        

    

    

        
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号

    













    
  • 
        
    
            
    
                
                    
                    
    PHP学习
    
                    
            
    
        
    
    
    • 
    
  • 
        
    
            
    
                
                    
                    
    技术支持
    
                    
            
    
        
    
    
    • 
    
  • 
        
    
            
    
                
                    
                    
    返回顶部
    
                    
            
    
        
    
    
    •