使用线程执行框架的一次过程

                public void run() { 

                    parseMsg(msg); 

                } 

            }); 

        } catch (Throwable e) { 

            System.out.println("消息处理异常" + e); } } /** * 比较耗时的消息处理流程 */ public void parseMsg(Message message) { while (true) { try { System.out.println("解析消息：" + message); Thread.sleep(5000); System.out.println("============================"); } catch (InterruptedException e) { 

                e.printStackTrace(); 

            } 

        } 

    } 

} 

效果：这种方案导致的现象是接收到的消息会迅速堆积，我们从消息队列（或者其他地方）取出了大量消息，但是处理线程的速度又跟不上，所以导致的问题是大量的Task会堆积在线程池底层维护的一个阻塞队列中，这会极大的耗费存储空间，影响系统的性能。

分析：当execute()一个任务的时候，如果有空闲的worker线程，那么投入运行，否则看设置的***线程个数，没有达到线程个数限制就创建新线程，接新任务，否则就把任务缓冲到一个阻塞队列中，问题就是这个队列，默认的大小是没有限制的，所以就会大量的堆积任务，必然耗费heap空间。

（编辑：焦作站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!