任务列表分派给多个线程的策略和方法（精）

《任务列表分派给多个线程的策略和方法（精）》由会员上传分享，免费在线阅读，更多相关内容在工程资料-天天文库。

1、多线程下载由来已久,如FlashGet、NetAnts等工具，它们都是依懒于HTTP协议的支持（Range字段指定请求内容范围），首先能读取出请求内容（即欲下载的文件）的大小，划分出若干区块，把区块分段分发给每个线程去下载，线程从本段起始处卜-载数据及至段尾，多个线程下载的内容最终会写入到同一个文件中。只研究有用的，工作中的需求：要把多个任务分派给多个线程去执行，这其中就会冇一个任务列衣指派到线程的策略思考：已知：1.一•个待执行的任务列表，2.指定耍启动的线程数；问题是：每个线程实际要执行哪些任务。策略是：任务列衣连

2、续按线程数分段，先保证每线程平均能分配到的任务数，余下的任务从前至后依次附加到线程中••只是数量上，实际每个线程执行的任务都还是连续的。如果出现那种僧多（线程）粥（任务）少的情况，实际启动的线程数就等于任务数，一挑一。这里只实现了每个线程各扫自家门前雪，动作快的完成厉眼见别的线程再累都是爱莫能助。实现及演示代码如下：由三个类实现，写在了一个java文件TaskDistributor为任务分发器，Task为待执行的任务，WorkThread为自定的工作线程。代码中运用了命令模式，如若能配以监听器，用上观察者模式來控制UI

3、显示就更绝妙不过了,就能实现像下载中的区块着色跳跃的动感了，在此定义下一步的着眼点了。代码中有较为详细的注释，看这些注释和执行结果就很容易理解的。main（）是测试方法packagecom.unmi.common;importjava.util.ArrayList;importjava.util.List;/***指派任务列表给线程的分发器*@authorUnmi*CQ:1125535Email:fantasia@sina.com*MSN:kypfos@msn.com2008-03-25*/publicclassTas

4、kDistributor{y***测试方法*@paramargs*/publicstaticvoidmain（String[]args）{〃初始化要执行的任务列表ListtaskList=newArrayList（）;for(inti=0;i<10&i++){taskList.add(newTask(i));}〃设定耍卅动的工作线程数为5个intthreadCount=5;List[]taskListPerThread=distributeTasks(taskList,threadC

5、ount);System.out.printing实际要启动的工作线程数:"+taskListPerThread.length);for(inti=0;i)就表明将启动多少个工作线程*@paramta

6、skList待分派的任务列表*@paramthreadCount线程数*@return列衣的数组，每个元素屮存冇该线程要执行的任务列表*/publicstaticList[]distributeTasks(ListtaskList,intthreadCount){//每个线程至少要执行的任务数，假如不为零则表示毎个线程都会分配到任务intminTaskCount=taskList.size()/threadCount;//平均分配后还剩下的任务数，不为零则还冇任务依个附加到前而的线程中intre

7、mainTaskCount=taskList.size()%threadCount;//实际要启动的线程数，如果工作线程比任务还多//自然只需要启动与任务相同个数的工作线程，一对一的执行//毕竟不打算实现了线程池，所以用不着预先初始化好休眠的线程intactualThreadCount=minTaskCount>0?threadCount:remainTaskCount;〃要启动的线程数组，以及每个线程要执行的任务列表List[]taskListPerThread=newList[actualThreadC

8、ount];inttaskindex=0;〃平均分配后多余任务，每附加给一个线程后的剩余数，重新声明与remainTaskCount〃相同的变量，不然会在执行中改变remainTaskCount原有值，产生•麻烦intremainlndees=remainTaskCount;for(inti=0;i