大家好,又见面了,我是你们的朋友全栈君。
package main.com.lift;
import com.google.common.collect.Lists;
import java.util.List;
import java.util.Queue;
import java.util.concurrent.Callable;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.LinkedBlockingQueue;
public class Task implements Callable<Queue<Integer>> {
List<Integer> loucengList;
CyclicBarrier cyclicBarrier;
LinkedBlockingQueue<Integer> queue;
public Task(CyclicBarrier cyclicBarrier,List<Integer> loucengList,LinkedBlockingQueue<Integer> queue){
this.cyclicBarrier=cyclicBarrier;
this.loucengList=loucengList;
this.queue=queue;
}
@Override
public Queue<Integer> call() throws Exception {
Queue<Integer> childQueue= Lists.newLinkedList();
try{
cyclicBarrier.await();
do{
synchronized (queue){
if(queue.size()>0){
int a=queue.poll();
if(loucengList.toString().contains(a+"")){
childQueue.offer(a);
}else {
queue.offer(a);
}
}
}
System.out.println(","+queue.size());
}while (queue.size()>0);
}catch (Exception e){
e.printStackTrace();
}
return childQueue;
}
}
发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/105943.html原文链接:https://javaforall.cn
【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛
【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...