- 浏览: 353157 次
- 性别:
- 来自: 北京
文章分类
最新评论
-
zzy2011266:
以上是特殊情况, 正确的方式是打开windowsshowVi ...
Android 出现 Your project contains errors, please fix them 。。。。 -
小奶牛:
BFGFG[b][/b]
PHP计算字符串长度 -
小奶牛:
[b][/b]YTYTY
PHP计算字符串长度 -
yuankunliu:
这样处理ppt里边的文本框在图片中有边框,知道怎么去掉不请问? ...
java转换ppt为图片 -
vtrtbb:
哦,我试试
简单的JS分页代码
只研究有用的,工作中的需求:要把多个任务分派给多个线程去执行,这其中就会有一个任务列表指派到线程的策略思考:已知:1. 一个待执行的任务列表,2. 指定要启动的线程数;问题是:每个线程实际要执行哪些任务。
策略是:任务列表连续按线程数分段,先保证每线程平均能分配到的任务数,余下的任务从前至后依次附加到线程中--只是数量上,实际每个线程执行的任务都还是连续的。如果出现那种僧多(线程) 粥(任务) 少的情况,实际启动的线程数就等于任务数,一挑一。这里只实现了每个线程各扫自家门前雪,动作快的完成后眼见别的线程再累都是爱莫能助。
实现及演示代码如下:由三个类实现,写在了一个 java 文件中:TaskDistributor 为任务分发器,Task 为待执行的任务,WorkThread 为自定的工作线程。代码中运用了命令模式,如若能配以监听器,用上观察者模式来控制 UI 显示就更绝妙不过了,就能实现像下载中的区块着色跳跃的动感了,在此定义下一步的着眼点了。
代码中有较为详细的注释,看这些注释和执行结果就很容易理解的。main() 是测试方法
package com.unmi.common; import java.util.ArrayList; import java.util.List; public class TaskDistributor { /** * 测试方法 * @param args */ public static void main(String[] args) { //初始化要执行的任务列表 List taskList = new ArrayList(); for (int i = 0; i < 108; i++) { taskList.add(new Task(i)); } //设定要启动的工作线程数为 5 个 int threadCount = 5; List[] taskListPerThread = distributeTasks(taskList, threadCount); System.out.println("实际要启动的工作线程数:"+taskListPerThread.length); for (int i = 0; i < taskListPerThread.length; i++) { Thread workThread = new WorkThread(taskListPerThread[i],i); workThread.start(); } } /** * 把 List 中的任务分配给每个线程,先平均分配,剩于的依次附加给前面的线程 * 返回的数组有多少个元素 (List) 就表明将启动多少个工作线程 * @param taskList 待分派的任务列表 * @param threadCount 线程数 * @return 列表的数组,每个元素中存有该线程要执行的任务列表 */ public static List[] distributeTasks(List taskList, int threadCount) { // 每个线程至少要执行的任务数,假如不为零则表示每个线程都会分配到任务 int minTaskCount = taskList.size() / threadCount; // 平均分配后还剩下的任务数,不为零则还有任务依个附加到前面的线程中 int remainTaskCount = taskList.size() % threadCount; // 实际要启动的线程数,如果工作线程比任务还多 // 自然只需要启动与任务相同个数的工作线程,一对一的执行 // 毕竟不打算实现了线程池,所以用不着预先初始化好休眠的线程 int actualThreadCount = minTaskCount > 0 ? threadCount : remainTaskCount; // 要启动的线程数组,以及每个线程要执行的任务列表 List[] taskListPerThread = new List[actualThreadCount]; int taskIndex = 0; //平均分配后多余任务,每附加给一个线程后的剩余数,重新声明与 remainTaskCount //相同的变量,不然会在执行中改变 remainTaskCount 原有值,产生麻烦 int remainIndces = remainTaskCount; for (int i = 0; i < taskListPerThread.length; i++) { taskListPerThread[i] = new ArrayList(); // 如果大于零,线程要分配到基本的任务 if (minTaskCount > 0) { for (int j = taskIndex; j < minTaskCount + taskIndex; j++) { taskListPerThread[i].add(taskList.get(j)); } taskIndex += minTaskCount; } // 假如还有剩下的,则补一个到这个线程中 if (remainIndces > 0) { taskListPerThread[i].add(taskList.get(taskIndex++)); remainIndces--; } } // 打印任务的分配情况 for (int i = 0; i < taskListPerThread.length; i++) { System.out.println("线程 " + i + " 的任务数:" + taskListPerThread[i].size() + " 区间[" + taskListPerThread[i].get(0).getTaskId() + "," + taskListPerThread[i].get(taskListPerThread[i].size() - 1).getTaskId() + "]"); } return taskListPerThread; } } /** * 要执行的任务,可在执行时改变它的某个状态或调用它的某个操作 * 例如任务有三个状态,就绪,运行,完成,默认为就绪态 * 要进一步完善,可为 Task 加上状态变迁的监听器,因之决定UI的显示 */ class Task { public static final int READY = 0; public static final int RUNNING = 1; public static final int FINISHED = 2; private int status; //声明一个任务的自有业务含义的变量,用于标识任务 private int taskId; //任务的初始化方法 public Task(int taskId){ this.status = READY; this.taskId = taskId; } /** * 执行任务 */ public void execute() { // 设置状态为运行中 setStatus(Task.RUNNING); System.out.println("当前线程 ID 是:" + Thread.currentThread().getName() +" | 任务 ID 是:"+this.taskId); // 附加一个延时 try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } // 执行完成,改状态为完成 setStatus(FINISHED); } public void setStatus(int status) { this.status = status; } public int getTaskId() { return taskId; } } /** * 自定义的工作线程,持有分派给它执行的任务列表 */ class WorkThread extends Thread { //本线程待执行的任务列表,你也可以指为任务索引的起始值 private List taskList = null; private int threadId; /** * 构造工作线程,为其指派任务列表,及命名线程 ID * @param taskList 欲执行的任务列表 * @param threadId 线程 ID */ public WorkThread(List taskList,int threadId) { this.taskList = taskList; this.threadId = threadId; } /** * 执行被指派的所有任务 */ public void run() { for (Task task : taskList) { task.execute(); } } }
执行结果如下,注意观察每个线程分配到的任务数量及区间。直到所有的线程完成了所分配到的任务后程序结束:
线程 0 的任务数:22 区间[0,21]
线程 1 的任务数:22 区间[22,43]
线程 2 的任务数:22 区间[44,65]
线程 3 的任务数:21 区间[66,86]
线程 4 的任务数:21 区间[87,107]
实际要启动的工作线程数:5
当前线程 ID 是:Thread-0 | 任务 ID 是:0
当前线程 ID 是:Thread-1 | 任务 ID 是:22
当前线程 ID 是:Thread-2 | 任务 ID 是:44
当前线程 ID 是:Thread-3 | 任务 ID 是:66
当前线程 ID 是:Thread-4 | 任务 ID 是:87
当前线程 ID 是:Thread-0 | 任务 ID 是:1
当前线程 ID 是:Thread-1 | 任务 ID 是:23
当前线程 ID 是:Thread-2 | 任务 ID 是:45
发表评论
-
Maven运行Selenium报错org/w3c/dom/ElementTraversal
2017-06-21 17:11 609Maven运行Selenium报错org/w3c/dom/ ... -
logback日志按天滚动记录
2017-05-09 11:25 2276<?xml version="1.0&quo ... -
spring boot 中用Swagger2 构建API说明文档
2017-05-05 12:10 462maven: <dependency> ... -
SpringMVC测试框架Mock[转载]
2017-02-22 15:09 2714基于RESTful风格的SpringMVC的测试,我们 ... -
maven本地安装jar包
2016-07-22 17:32 442mvn install:install-file -Dfil ... -
java发消息MSMQ
2014-03-31 11:29 1337java发送消息给微软MSMQ的组件 -
maven导出依赖jar包到指定目录
2014-01-22 15:35 680项目建立后,导出依赖jar包到指定目录: mvn d ... -
hadoop执行hadoop namenode -format错误问题
2013-01-02 20:54 9169运行时遇到如下问题: Exception in thread ... -
sql 每个分类取N条数据例子
2012-12-30 09:43 5602取得分组TOP-N测试表与测试数据 CREATE TABLE ... -
effective java第一版系在
2012-12-17 09:16 723做个备注吧,以后又找不到了 -
java代码构建线程池
2012-11-15 21:48 727在现代的操作系统中, ... -
BugFree说明
2012-08-06 11:55 749BugFree 说明 Fixed 已修复 ... -
android 阅读器分页读取字数
2012-06-05 12:33 3219// 本方法 分行又分页 public static ... -
linux更新系统时间
2012-01-11 10:23 1497检查是否安装过ntp rpm -aq | g ... -
jstl 一些函数用法
2011-11-29 09:44 751fn函数里面有很多好用的方法 <%@ taglib ... -
activeMq 简单的安全设置
2011-11-25 18:40 1128在conf 中找到 jetty.xml 文件 < ... -
activeMq收不到消息
2011-11-25 18:36 1087项目需要应用jms,在本地测试好的,到了服务器就后可以看 ... -
仿goolge验证码,自己没有试过
2011-10-13 14:55 962仿goolge验证码,自己没有试过 -
Tomcat 配置数据源
2011-09-22 15:22 959<Resource name="jdbc/ ... -
svn eclipse插件地址
2011-09-22 10:22 680Links for 1.6.x Release:Changel ...
相关推荐
易语言多线程执行任务例程。
多线程执行任务具体实现方式;
NULL 博文链接:https://mammahao.iteye.com/blog/2226890
易语言多线程执行任务例程
声明BigJob 对 像(包括事件),创建BigJob 的实 例,通知对像执行任务,在对像的“ 开 始”事件中给用户一些提示,数字时钟”在不间断地显示当前时间。 不足之处:终止任务(关闭窗体)时 Activex.exe 部件需要...
C#,编写的多线程执行处理程序,同时执行多个任务,共大家参考。
(原创)asp.net利用多线程执行长时间的任务,客户端显示出任务的执行进度的示例(一
使用线程池管理多线程上传,包含了文件拆分,文件分片多线程上传,单文件上传。多线程执行任务等待管理。拒绝直接new Thread创建新线程导致的诸多问题
主要实现了,多个线程任务在同时执行的情况下,保证线程任务顺序的问题。更通俗来说,就是保证Thread1一定在thread2,thread3之后才能执行。另外,代码里我写了详细的注释,和测试的效果,绝对让你能看懂。还有我传的...
多线程有很好的并发性即无序性,在某些特殊情况下需要用到多线程然而又要使其具备顺序性,这种时候就有了一个特殊的场景那就是多线程顺序执行,在现在VS2015中Task自带了顺序执行的方法,但在此之前的旧项目中如果...
Java多线程实现数据切割批量执行,实现限流操作。 java线程池Executors实现数据批量操作。 批量异步Executors处理数据,实现限流操作,QPS限流。 线程池调用第三方接口限流实现逻辑。 案例适合: 1.批量处理大数据。...
代码采用多工作者多线程执行任务。通过暴露的方法往工作者传递消息,然后采用事件回调返回处理结果,实现的事件有OnThreadComplete,OnAddedTask,OnStart,OnSuccess,OnFailure,OnTimeout。 事件回调支持同步或...
2. 然后在线程池execute方法中,每个线程都执行一次ready.countDown()方法修改计数值 3. 在线程池中每个线程执行ready.countD
此前被面试问道一道面试题,B,C线程都有自己的任务,A线程要在B,C线程都结束后开始执行,并且不允许有A线程循环等待空耗CPU现象。
C#多线程实现进程管理(同步执行)
VC 创建多个 Thread多线程,用以执行不同任务的例子,运行程序后你可看到分别有红色、蓝色的小球,在沿各自不同的轨迹做运动,在代码中,我们创建了一个小球运动线程的主函数,分别用两个线程调用这个函数,但设定的...
spring定时任务 spring多线程的一个简单示例。
由三个类实现,写在了一个 Java 文件中:TaskDistributor 为任务分发器,Task 为待执行的任务,WorkThread 为自定的工作线程。代码中运用了命令模式,如若能配以监听器,用上观察者模式来控制 UI 显示就更绝妙不过了...
不精通线程、不擅长对多线程进行管理,就不可能在当今多CPU多核心的年代写出优秀的程序代码,软件的性能将会大打折扣。本文及其示例代码,诠释System.Classes.pas中的(多)线程 和System.SyncObjs.pas (深入应用...