這篇文章給大家介紹如何進行Java多線程循環(huán)相關的代碼介紹,內(nèi)容非常詳細,感興趣的小伙伴們可以參考借鑒,希望對大家能有所幫助。
洪澤網(wǎng)站建設公司創(chuàng)新互聯(lián),洪澤網(wǎng)站設計制作,有大型網(wǎng)站制作公司豐富經(jīng)驗。已為洪澤近千家提供企業(yè)網(wǎng)站建設服務。企業(yè)網(wǎng)站搭建\成都外貿(mào)網(wǎng)站建設要多少錢,請找那個售后服務好的洪澤做網(wǎng)站的公司定做!
Java多線程循環(huán)需要我們不斷的學習,有很多的問題一直是我們相互關心的。下面我們就來看看如何才能更好的使用這門編程語言。當每個迭代彼此獨立,并且完成循環(huán)體中每個迭代的工作,意義都足夠重大,足以彌補管理一個新任務的開銷時,這個順序循環(huán)是適合并行化的。
public
voidParallelRecursive(final Executorexec,
List>nodes,Collection results){ for(Node
n:nodes){ exec.execute(new Runnable(){
public void run(){
results.add(n.compute());
}
});
parallelRecursive(exec,n.getChildren(),results);
}
}
public
Collection getParallelResults(List >nodes) throws InterruptedException{
ExecutorService exec=Executors.newCachedThreadPool();
Queue
resultQueue=newConcurrentLinkedQueue (); parallelRecursive(exec,nodes,resultQueue);
exec.shutdown();
exec.awaitTermination(Long.MAX_VALUE,TimeUnit.SECONDS);
return reslutQueue;
}
但是以上程序不能處理不存在任何方案的情況,而下列程序可以解決這個問題
public class PuzzleSolver
extendsConcurrent
PuzzleSolver{
...
privatefinal AtomicInteger taskCount=new AtomicInteger(0);
protectedRunnable newTask(P p,M m,Node
n){
return new CountingSolverTask(p,m,n);
}
classCountingSolverTask extends SolverTask{
CountingSolverTask(P pos,Mmove,Node
prev){
super(pos,move,prev);
taskCount.incrementAndGet();
}
publicvoid run(){
try{
super.run();
}
finally{
if (taskCount.decrementAndGet()==0)
solution.setValue(null);
}
}
}
}
關于如何進行Java多線程循環(huán)相關的代碼介紹就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,可以學到更多知識。如果覺得文章不錯,可以把它分享出去讓更多的人看到。