Java之线程池简单实现.docxVIP

  1. 1、有哪些信誉好的足球投注网站(book118)网站文档一经付费(服务费),不意味着购买了该文档的版权,仅供个人/单位学习、研究之用,不得用于商业用途,未经授权,严禁复制、发行、汇编、翻译或者网络传播等,侵权必究。。
  2. 2、本站所有内容均由合作方或网友上传,本站不对文档的完整性、权威性及其观点立场正确性做任何保证或承诺!文档内容仅供研究参考,付费前请自行鉴别。如您付费,意味着您自己接受本站规则且自行承担风险,本站不退款、不进行额外附加服务;查看《如何避免下载的几个坑》。如果您已付费下载过本站文档,您可以点击 这里二次下载
  3. 3、如文档侵犯商业秘密、侵犯著作权、侵犯人身权等,请点击“版权申诉”(推荐),也可以打举报电话:400-050-0827(电话支持时间:9:00-18:30)。
  4. 4、该文档为VIP文档,如果想要下载,成为VIP会员后,下载免费。
  5. 5、成为VIP后,下载本文档将扣除1次下载权益。下载后,不支持退款、换文档。如有疑问请联系我们
  6. 6、成为VIP后,您将拥有八大权益,权益包括:VIP文档下载权益、阅读免打扰、文档格式转换、高级专利检索、专属身份标志、高级客服、多端互通、版权登记。
  7. 7、VIP文档为合作方或网友上传,每下载1次, 网站将根据用户上传文档的质量评分、类型等,对文档贡献者给予高额补贴、流量扶持。如果你也想贡献VIP文档。上传文档
查看更多
Java之线程池简单实现

Java之线程池简单实现以前做的东西,实现一个简单的多线程机制,开始之前,现说说原理性的东西吧,下面是我在ibm开发者上搜到的内容线程池的技术背景在面向对象编程中,创建和销毁对象是很费时间的,因为创建一个对象要获取内存资源或者其它更多资源。在Java中更是如此,虚拟机将试图跟踪每一个对象, 以便能够在对象销毁后进行垃圾回收。所以提高服务程序效率的一个手段就是尽可能减少创建和销毁对象的次数,特别是一些很耗资源的对象创建和销毁。如何利用 已有对象来服务就是一个需要解决的关键问题,其实这就是一些池化资源技术产生的原因。多线程技术主要解决处理器单元内多个线程执行的问题,它可以显著减少处理器单元的闲置时间,增加处理器单元的吞吐能力。但如果对多线程应用不当,会增加对单个任务的处理时间。可以举一个简单的例子:假设在一台服务器完成一项任务的时间为T◆? T1 创建线程的时间◆ T2 在线程中执行任务的时间,包括线程间同步所需时间◆ T3 线程销毁的时间显然T = T1+T2+T3。注意这是一个极度简化的假设。可以看出T1,T3是多线程本身的带来的开销,我们渴望减少T1,T3所用的时间,从而减少T的时间。但一些线程的使用者并没有注意到 这一点,所以在程序中频繁的创建或销毁线程,这导致T1和T3在T中占有相当比例。显然这是突出了线程的弱点(T1,T3),而不是优点(并发性)。线程池技术正是关注如何缩短或调整T1,T3时间的技术,从而提高服务器程序性能的。它把T1,T3分别安排在服务器程序的启动和结束的时间段或者一些空闲的时间段,这样在服务器程序处理客户请求时,不会有T1,T3的开销了。线程池不仅调整T1,T3产生的时间段,而且它还显著减少了创建线程的数目。在看一个例子:假设一个服务器一天要处理50000个请求,并且每个请求需要一个单独的线程完成。我们比较利用线程池技术和不利于线程池技术的服务器 处理这些请求时所产生的线程总数。在线程池中,线程数一般是固定的,所以产生线程总数不会超过线程池中线程的数目或者上限(以下简称线程池尺寸),而如果 服务器不利用线程池来处理这些请求则线程总数为50000。一般线程池尺寸是远小于50000。所以利用线程池的服务器程序不会为了创建50000而在处 理请求时浪费时间,从而提高效率。这些都是假设,不能充分说明问题,下面我将讨论线程池的简单实现并对该程序进行对比测试,以说明线程技术优点及应用领域。一般一个简单线程池至少包含下列组成部分◆ 线程池管理器(ThreadPoolManager):用于创建并管理线程池◆ 工作线程(WorkThread): 线程池中线程◆ 任务接口(Task):每个任务必须实现的接口,以供工作线程调度任务的执行。◆ 任务队列:用于存放没有处理的任务。提供一种缓冲机制。线程池管理器至少有下列功能:创建线程池,销毁线程池,添加新任务。下面就是小弟的实现,还是欢迎拍砖哈:public?class?ThreadPoolManager?{ ?????private?static?ThreadPoolManager?instance?=?null; ?????private?ListUpload?taskQueue?=?Collections.synchronizedList(new?LinkedListUpload());//任务队列 ?????private?WorkThread[]?workQueue?;????//工作线程(真正执行任务的线程) ?????private?static?int?worker_num?=?5;????//工作线程数量(默认工作线程数量是5) ?????private?static?int?worker_count?=?0; ????? ?????private?ThreadPoolManager(){ ?????????this(5); ?????} ?????private?ThreadPoolManager(int?num){ ?????????worker_num?=?num; ?????????workQueue?=?new?WorkThread[worker_num]; ?????????for(int?i=0;iworker_num;i++){ ?????????????workQueue[i]?=?new?WorkThread(i); ?????????} ?????} ????? ?????public?static?synchronized?ThreadPoolManager?getInstance(){ ?????????if(instance==null) ?????????????instance?=?new?ThreadPoolManager(

文档评论(0)

qiwqpu54 + 关注
实名认证
文档贡献者

该用户很懒,什么也没介绍

1亿VIP精品文档

相关文档