Android线程池控制并发数多线程下载

2023-09-01 21:30:04 64

多线程下载并不是并发下载线程越多越好，因为当用户开启太多的并发线程之后，应用程序需要维护每条线程的开销，线程同步的开销。

这些开销反而会导致下载速度降低。因此需要避免在代码中直接开启大量线程执行下载。

主要实现步奏：

1、定义一个DownUtil类，下载工作基本在此类完成，在构造器中初始化UI线程的Handler。用于子线程和UI线程传递下载进度值。

2、所有的下载任务都保存在LinkedList。在init（）方法中开启一个后台线程，不断地从LinkedList中取任务交给线程池中的空闲线程执行。

3、每当addTask方法添加一个任务，就向mPoolThreadHandler发送条消息，就从任务队列中取出一个任务交给线程池执行。这里使用了使用了Semaphore信号量，也就是说只有当一个任务执行完成之后，release（）一个信号量，才能从LinkedList中取出一个任务再去执行，否则acquire（）方法会一直阻塞线程，直到上一个任务完成。

publicclassDownUtil
{
//定义下载资源的路径
privateStringpath;
//指定下载文件的保存位置
privateStringtargetFile;
//定义下载文件的总大小
privateintfileSize;

//线程池
privateExecutorServicemThreadPool;
//线程数量
privatestaticfinalintDEFAULT_THREAD_COUNT=5;
//任务队列
privateLinkedListmTasks;

//后台轮询线程
privateThreadmPoolThread;
//后台线程的handler
privateHandlermPoolThreadHandler;
//UI线程的Handler
privateHandlermUIThreadHandler;
//信号量
privateSemaphoresemaphore;
privateSemaphoremHandlerSemaphore=newSemaphore(0);
//下载线程数量
privateintthreadNum;

publicDownUtil(Stringpath,StringtargetFile,intthreadNum,finalProgressBarbar)
{
this.path=path;
this.targetFile=targetFile;
this.threadNum=threadNum;
init();

mUIThreadHandler=newHandler()
{
intsumSize=0;
@Override
publicvoidhandleMessage(Messagemsg)
{
if(msg.what==0x123)
{
intsize=msg.getData().getInt("upper");
sumSize+=size;
Log.d("sumSize",sumSize+"");
bar.setProgress((int)(sumSize*1.0/fileSize*100));
}
}
};
}

privatevoidinit()
{
mPoolThread=newThread()
{
publicvoidrun()
{
Looper.prepare();
mPoolThreadHandler=newHandler()
{
publicvoidhandleMessage(Messagemsg)
{
if(msg.what==0x111)
{
mThreadPool.execute(getTask());
try
{
semaphore.acquire();
}
catch(InterruptedExceptione)
{
e.printStackTrace();
}
}
}
};
mHandlerSemaphore.release();
Looper.loop();
}
};
mPoolThread.start();

mThreadPool=Executors.newFixedThreadPool(DEFAULT_THREAD_COUNT);
mTasks=newLinkedList<>();
semaphore=newSemaphore(DEFAULT_THREAD_COUNT);
}

publicvoiddownLoad()
{


try{
URLurl=newURL(path);
HttpURLConnectionconn=(HttpURLConnection)url.openConnection();
conn.setConnectTimeout(5*1000);
conn.setRequestMethod("GET");
conn.setRequestProperty(
"Accept",
"image/gif,image/jpeg,image/pjpeg,image/pjpeg,"
+"application/x-shockwave-flash,application/xaml+xml,"
+"application/vnd.ms-xpsdocument,application/x-ms-xbap,"
+"application/x-ms-application,application/vnd.ms-excel,"
+"application/vnd.ms-powerpoint,application/msword,*/*");
conn.setRequestProperty("Accept-Language","zh-CN");
conn.setRequestProperty("Charset","UTF-8");
conn.setRequestProperty("Connection","Keep-Alive");

//得到文件的大小
fileSize=conn.getContentLength();
conn.disconnect();

intcurrentPartSize=fileSize/threadNum+1;
RandomAccessFilefile=newRandomAccessFile(targetFile,"rw");
file.setLength(fileSize);
file.close();


for(inti=0;i0)
{
currentPart.write(buffer,0,hasRead);
//累计该线程下载的总大小
length+=hasRead;
}

Log.d("length",length+"");

//创建消息
Messagemsg=newMessage();
msg.what=0x123;
Bundlebundle=newBundle();
bundle.putInt("upper",length);
msg.setData(bundle);
//向UI线程发送消息
mUIThreadHandler.sendMessage(msg);

semaphore.release();
currentPart.close();
inStream.close();
}
catch(Exceptione)
{
e.printStackTrace();
}
}
}

publicstaticvoidskipFully(InputStreamin,longbytes)throwsIOException
{
longremaining=bytes;
longlen=0;
while(remaining>0)
{
len=in.skip(remaining);
remaining-=len;
}
}
}

以下是MainActivity的代码：

publicclassMainActivityextendsActivity
{
EditTexturl;
EditTexttarget;
ButtondownBn;
ProgressBarbar;
DownUtildownUtil;
privateStringsavePath;

@Override
protectedvoidonCreate(BundlesavedInstanceState)
{
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
//获取界面中的四个界面控件
url=(EditText)findViewById(R.id.address);
target=(EditText)findViewById(R.id.target);
try
{
FilesdCardDir=Environment.getExternalStorageDirectory();
savePath=sdCardDir.getCanonicalPath()+"/d.chm";
}
catch(Exceptione)
{
e.printStackTrace();
}
target.setText(savePath);
downBn=(Button)findViewById(R.id.down);
bar=(ProgressBar)findViewById(R.id.bar);
downBn.setOnClickListener(newView.OnClickListener()
{
@Override
publicvoidonClick(Viewview)
{
downUtil=newDownUtil(url.getText().toString(),target.getText().toString(),7,bar);
newThread()
{
@Override
publicvoidrun()
{
try
{
downUtil.downLoad();
}
catch(Exceptione)
{
e.printStackTrace();
}
}
}.start();
}
});
}
}

页面布局比较简单这里一并贴出：

此例主要是在李刚老师的《疯狂Java的讲义》的多线程的例子上修改，感谢李刚老师，如有不足之处，欢迎批评指正。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

Android线程池控制并发数多线程下载

热门推荐

随机推荐