知识大全任务列表分派给多个线程的策略和方法

Posted 2022-07-18 知

篇首语：历史和哲学负有多种永恒的责任，同时也是简单的责任。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全任务列表分派给多个线程的策略和方法相关的知识，希望对你有一定的参考价值。

　　多线程下载由来已久如 FlashGet NetAnts 等工具它们都是依懒于 HTTP 协议的支持(Range 字段指定请求内容范围) 首先能读取出请求内容 (即欲下载的文件) 的大小划分出若干区块把区块分段分发给每个线程去下载线程从本段起始处下载数据及至段尾多个线程下载的内容最终会写入到同一个文件中

　　只研究有用的工作中的需求要把多个任务分派给多个线程去执行这其中就会有一个任务列表指派到线程的策略思考已知一个待执行的任务列表指定要启动的线程数;问题是每个线程实际要执行哪些任务

　　策略是任务列表连续按线程数分段先保证每线程平均能分配到的任务数余下的任务从前至后依次附加到线程中只是数量上实际每个线程执行的任务都还是连续的如果出现那种僧多(线程) 粥(任务) 少的情况实际启动的线程数就等于任务数一挑一这里只实现了每个线程各扫自家门前雪动作快的完成后眼见别的线程再累都是爱莫能助

　　实现及演示代码如下由三个类实现写在了一个 java 文件中 TaskDistributor 为任务分发器 Task 为待执行的任务 WorkThread 为自定的工作线程代码中运用了命令模式如若能配以监听器用上观察者模式来控制 UI 显示就更绝妙不过了就能实现像下载中的区块着色跳跃的动感了在此定义下一步的着眼点了

　　代码中有较为详细的注释看这些注释和执行结果就很容易理解的 main() 是测试方法

　　　package mon; 　　import java util ArrayList; 　　import java util List; 　　/** 　　* 指派任务列表给线程的分发器　　* @author Unmi 　　* QQ: Email: 　　* MSN: 　　*/ 　　public class TaskDistributor 　　/** 　　* 测试方法　　* @param args 　　*/ 　　public static void main(String[] args) 　　//初始化要执行的任务列表　　List taskList = new ArrayList(); 　　for (int i = ; i < ; i++) 　　taskList add(new Task(i)); 　　　　//设定要启动的工作线程数为个　　int threadCount = ; 　　List[] taskListPerThread = distributeTasks(taskList threadCount); 　　System out println( 实际要启动的工作线程数 +taskListPerThread length); 　　for (int i = ; 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 > ? threadCount : remainTaskCount; 　　// 要启动的线程数组以及每个线程要执行的任务列表　　List[] taskListPerThread = new List[actualThreadCount]; 　　int taskIndex = ; 　　//平均分配后多余任务每附加给一个线程后的剩余数重新声明与 remainTaskCount 　　//相同的变量不然会在执行中改变 remainTaskCount 原有值产生麻烦　　int remainIndces = remainTaskCount; 　　for (int i = ; i < taskListPerThread length; i++) 　　taskListPerThread[i] = new ArrayList(); 　　// 如果大于零线程要分配到基本的任务　　if (minTaskCount > ) 　　for (int j = taskIndex; j < minTaskCount + taskIndex; j++) 　　taskListPerThread[i] add(taskList get(j)); 　　　　taskIndex += minTaskCount; 　　　　// 假如还有剩下的则补一个到这个线程中　　if (remainIndces > ) 　　taskListPerThread[i] add(taskList get(taskIndex++)); 　　remainIndces ; 　　　　　　// 打印任务的分配情况　　for (int i = ; i < taskListPerThread length; i++) 　　System out println( 线程 + i + 的任务数 + 　　taskListPerThread[i] size() + 区间[ 　　+ taskListPerThread[i] get( ) getTaskId() + 　　+ taskListPerThread[i] get(taskListPerThread[i] size() ) getTaskId() + ] ); 　　　　return taskListPerThread; 　　　　　　/** 　　* 要执行的任务可在执行时改变它的某个状态或调用它的某个操作　　* 例如任务有三个状态就绪运行完成默认为就绪态　　* 要进一步完善可为 Task 加上状态变迁的监听器因之决定UI的显示　　*/ 　　class Task 　　public static final int READY = ; 　　public static final int RUNNING = ; 　　public static final int FINISHED = ; 　　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( ); 　　 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(); 　　　　　　

　　执行结果如下注意观察每个线程分配到的任务数量及区间直到所有的线程完成了所分配到的任务后程序结束

　　上面坦白来只算是基本功夫贴出来还真见笑了还有更为复杂的功能

cha138/Article/program/Java/gj/201311/27458

知识大全 任务列表分派给多个线程的策略和方法

知识大全任务列表分派给多个线程的策略和方法