位置: 编程技术 - 正文

【java线程池】(java线程池创建)

编辑:rootadmin

推荐整理分享【java线程池】(java线程池创建),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:java线程池最佳实践,java线程池实战,java线程池的用法,java中线程池,java线程池原理,java线程池原理,java线程池队列有几种,java线程池的工作原理,内容如对您有帮助,希望把文章链接给更多的朋友!

文地址:jenkov 作者: Jakob Jenkov 译者:长源 校对:方腾飞

java线程池(Thread Pool)对于限制应用程序中同一时刻运行的线程数很有用。因为每启动一个新线程都会有相应的性能开销,每个线程都需要给栈分配一些内存等等。

我们可以把并发执行的任务传递给一个线程池,来替代为每个并发执行的任务都启动一个新的线程。只要池里有空闲的线程,任务就会分配给一个线程执行。在线程池的内部,任务被插入一个阻塞队列(Blocking Queue ),线程池里的线程会去取这个队列里的任务。当一个新任务插入队列时,一个空闲线程就会成功的从队列中取出任务并且执行它。

线程池经常应用在多线程服务器上。每个通过网络到达服务器的连接都被包装成一个任务并且传递给线程池。线程池的线程会并发的处理连接上的请求。以后会再深入有关 Java 实现多线程服务器的细节。

Java 5 在 java.util.concurrent 包中自带了内置的线程池,所以你不用非得实现自己的线程池。你可以阅读我写的 java.util.concurrent.ExecutorService 的文章以了解更多有关内置线程池的知识。不过无论如何,知道一点关于线程池实现的知识总是有用的。

【java线程池】(java线程池创建)

这里有一个简单的线程池实现:

public class ThreadPool { private BlockingQueue taskQueue = null; private List<PoolThread> threads = new ArrayList<PoolThread>(); private boolean isStopped = false; public ThreadPool(int noOfThreads, int maxNoOfTasks) { taskQueue = new BlockingQueue(maxNoOfTasks); for (int i=0; i<noOfThreads; i&#;&#;) { threads.add(new PoolThread(taskQueue)); } for (PoolThread thread : threads) { thread.start(); } } public void synchronized execute(Runnable task) { if(this.isStopped) throw new IllegalStateException("ThreadPool is stopped"); this.taskQueue.enqueue(task); } public synchronized boolean stop() { this.isStopped = true; for (PoolThread thread : threads) { thread.stop(); } }}复制代码<span style="color: rgb(, , ); font-family: Arial, Helvetica, sans-serif; line-height: px; widows: auto; background-color: rgb(, , );">(校注:原文有编译错误,我修改了下)</span>复制代码

线程池的实现由两部分组成。类 ThreadPool 是线程池的公开接口,而类 PoolThread 用来实现执行任务的子线程。

为了执行一个任务,方法 ThreadPool.execute(Runnable r) 用 Runnable 的实现作为调用参数。在内部,Runnable 对象被放入 阻塞队列 (Blocking Queue),等待着被子线程取出队列。

一个空闲的 PoolThread 线程会把 Runnable 对象从队列中取出并执行。你可以在 PoolThread.run() 方法里看到这些代码。执行完毕后,PoolThread 进入循环并且尝试从队列中再取出一个任务,直到线程终止。

调用 ThreadPool.stop() 方法可以停止 ThreadPool。在内部,调用 stop 先会标记 isStopped 成员变量(为 true)。然后,线程池的每一个子线程都调用 PoolThread.stop() 方法停止运行。注意,如果线程池的 execute() 在 stop() 之后调用,execute() 方法会抛出 IllegalStateException 异常。

子线程会在完成当前执行的任务后停止。注意 PoolThread.stop() 方法中调用了 this.interrupt()。它确保阻塞在 taskQueue.dequeue() 里的 wait() 调用的线程能够跳出 wait() 调用(校对注:因为执行了中断interrupt,它能够打断这个调用),并且抛出一个 InterruptedException 异常离开 dequeue() 方法。这个异常在PoolThread.run() 方法中被截获、报告,然后再检查 isStopped 变量。由于 isStopped 的&#;是 true, 因此PoolThread.run() 方法退出,子线程终止。

android录音开发 MediaRecorder类详解手机一般都有麦克风和摄像头,而Android系统就可以利用这些硬件来录制音视频了。为了增加对录制音视频的支持,Android系统提供了一

Android -- service两种启动方式startService与bindService 继上一篇文章,Android–Service的使用,我们来继续看看Service的两种启动方式第一种startService。运行代码,得知以下几点结论:我们了解它的启动周期为on

[android] listView解析 在android开发中ListView是比较常用的组件,它以列表的形式展示具体内容,并且能够根据数据的长度自适应显示。抽空把对ListView的使用做了整理,并写了

标签: java线程池创建

本文链接地址:https://www.jiuchutong.com/biancheng/376607.html 转载请保留说明!

上一篇:Android中Pull解析器解析xml文件案例(如何得到pull解析器?)

下一篇:android录音开发(app录音功能开发)

  • 核定征收季度核定销售额
  • 实收资本增加的原因
  • 企业会计准则利润表本期金额
  • 企业合并固定资产增值的规定
  • 增值税纳税义务发生时间
  • 酒店里的水电费怎么收
  • 研发试制的样机属于固定资产吗
  • 不能税前扣除的费用有哪些
  • 在汇兑结算方式中汇入行对流行代取的款项应先转入
  • 增值税的税负率就是用应缴纳的增值税总额
  • 增值税实际缴纳总额
  • 纳税人提供不动产租赁服务采取预收款方式
  • 支付境外销售佣金怎么做
  • 咨询费可以入账吗
  • 人工费用占销售收入比重
  • 餐饮消费,碰到商家不愿意开发票怎么办?
  • 企业在筹建期间发生的费用
  • 合同资产减值准备对应科目
  • 滴滴行程单修改后是否能查
  • 中小企业代扣代缴增值税抵扣时限
  • 取得的技术成果
  • 个人转让上市公司股票交增值税吗
  • 个体工商户未给员工缴纳社保
  • 如何在vue项目中导入外部的包
  • 退税有啥影响
  • apache24启动不了错误代码1
  • 除了个税还有什么税
  • find.exe应用程序错误
  • 什么时候使用多进程
  • 员工补偿金分录
  • 企业之间拆借资金
  • symerr函数
  • 销售货物代垫的运费会计分录
  • 企业出租房屋怎么做账
  • php框架symfony
  • 城市维护建设税减免税优惠政策
  • 确认收入的五个原则
  • 红冲费用如何处理
  • 增值税进项发票不够抵扣怎么办
  • 没收的定金收入怎么入账
  • php底部导航代码
  • mysql_real_query
  • 资产减值损失科目借方增加还是减少
  • 物流运输货损管理规定
  • 研究费用怎么做账
  • 事业单位利息收入
  • 投标保证金以现金形式转为履约保证金
  • 企业法人从公司怎么拿钱
  • 所有者权益科目有哪些
  • 当月增加的固定资产当月不计提折旧
  • 固定资产的主要特征
  • 购进货物的发票确认定虚开,所得税处理
  • 福利费取得的专票不能抵扣账怎么做
  • pg 正则表达式
  • win2008r2下载
  • 苹果电脑dock栏是什么意思
  • windows7 设置
  • linux 静态库
  • win7系统怎么禁止软件自启动
  • compaq-rba.exe是哪个方面的进程 作用是什么 compaq-rba进程查询
  • wind10升级
  • w10操作系统内部版本
  • 关闭迅雷安卓版自动更新
  • linux克隆虚拟机
  • jquery邮箱正则表达式
  • css ie8
  • unity中canvas怎么调框大小
  • android性能指标
  • 批处理文件是可执行文件吗
  • js如何使用
  • 安卓手机画画触屏笔推荐
  • js判断字符串字符出现的次数
  • u3d脚本语言
  • nodejs eventloop
  • javascript获取值
  • android回调函数
  • 单位纳税人什么意思
  • 零申报印花税的应税凭证名称怎么填写
  • 国税年收入
  • 纪检组长如何监督党员
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设