Java并发之串行线程池实例解析
前言
做Android的这两年时间，通过研究Android源码，也会Java并发处理多线程有了自己的一些理解。
那么问题来了，如何实现一个串行的线程池呢？
思路
何为串行线程池呢？
也就是说，我们的Runnable对象应该有个排队的机制，它们顺序从队列尾部进入，并且从队列头部选择Runnable进行执行。
既然我们有了思路，那我们就考虑一下所需要的数据结构？
既然是从队列尾部插入Runnable对象，从队列头部执行Runnable对象，我们自然需要一个队列。Java的SDK已经给我们提供了很好的队列数据结构，例如双端队列：ArrayDeque
- 因为涉及到线程的执行，那我们首先就需要有一个合适的线程池，使用ThreadPoolExecutor类即可构造。
- 既然是串行执行，那如何保持串行机制呢？我们可以通过try和finally机制，我们将传入的Runnable对象重新封装成一个新的Runnable对象，在新的Runnable的run方法的try块中执行Runnable的run方法，在finally中调用执行队列头部Runnable对象出队列，并放入线程池执行的方法。
示例代码
importjava.util.ArrayDeque;
importjava.util.concurrent.BlockingQueue;
importjava.util.concurrent.LinkedBlockingDeque;
importjava.util.concurrent.ThreadFactory;
importjava.util.concurrent.ThreadPoolExecutor;
importjava.util.concurrent.TimeUnit;
importjava.util.concurrent.atomic.AtomicInteger;
/**
*Createdbywzyon16-1-5.
*/
publicclassSerialExecutor{
privateRunnablemActive;
privateArrayDequemArrayDeque=newArrayDeque<>();
privatestaticfinalintCPU_COUNT=Runtime.getRuntime().availableProcessors();
privatestaticfinalintCORE_POOL_SIZE=CPU_COUNT+1;
privatestaticfinalintMAXIMUM_POOL_SIZE=CPU_COUNT*2+1;
privatestaticfinalintKEEP_ALIVE=1;
privatestaticfinalBlockingQueuesPoolWorkQueue=
newLinkedBlockingDeque<>(128);
privatestaticfinalThreadFactorysThreadFactory=newThreadFactory(){
privatefinalAtomicIntegermCount=newAtomicInteger(1);
@Override
publicThreadnewThread(Runnabler){
returnnewThread(r,"Serialthread#"+mCount.getAndIncrement());
}
};
privatestaticfinalThreadPoolExecutorTHREAD_EXECUTOR=newThreadPoolExecutor(CORE_POOL_SIZE,
MAXIMUM_POOL_SIZE,KEEP_ALIVE,TimeUnit.SECONDS,sPoolWorkQueue,sThreadFactory);
publicsynchronizedvoidexecute(finalRunnabler){
mArrayDeque.offer(newRunnable(){
@Override
publicvoidrun(){
try{
r.run();
}finally{
scheduleNext();
}
}
});
//第一次入队列时mActivie为空，因此需要手动调用scheduleNext方法
if(mActive==null){
scheduleNext();
}
}
privatevoidscheduleNext(){
if((mActive=mArrayDeque.poll())!=null){
THREAD_EXECUTOR.execute(mActive);
}
}
publicstaticvoidmain(String[]args){
SerialExecutorserialExecutor=newSerialExecutor();
for(inti=0;i<10;i++){
finalintj=i;
serialExecutor.execute(newRunnable(){
@Override
publicvoidrun(){
System.out.println("Thenumis:"+(j+1));
try{
Thread.sleep(1000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
}
});
}
}
}
执行结果如下：
Thenumis:1
Thenumis:2
Thenumis:3
Thenumis:4
Thenumis:5
Thenumis:6
Thenumis:7
Thenumis:8
Thenumis:9
Thenumis:10
总结
以上就是本文关于Java并发之串行线程池实例解析的全部内容，希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题，如有不足之处，欢迎留言指出。感谢朋友们对本站的支持！