public class PublishMsgTest {//创建固定大小为100 的线程池private static ExecutorService service = Executors.newFixedThreadPool(100);//发送消息的业务逻辑方法public int sendMsg(List<Integer> receivers,String content){long begin = System.nanoTime();AtomicInteger ai = new AtomicInteger(0);List<Future<Integer>> list = new ArrayList<>();//循环发送消息for(int i=0;i<receivers.size();i++){Integer receiver = receivers.get(i);//使用Future，Callable实现发送消息后返回发送结果Future<Integer> future = service.submit(new Callable<Integer>() {@Overridepublic Integer call() throws Exception {//调用相对比较耗时的发送消息接口Thread.sleep(200);//发送消息int resultStatus = sendMsg(receiver,content);System.out.println("接收者【"+receiver+"】,发送结果【"+resultStatus+"】");return resultStatus;}});list.add(future);}System.out.println("-----------------------"+(System.nanoTime()-begin)/1000_000d+"-----------------------");//循环接收发送结果，相当于一个使线程同步的过程，这个过程是比较耗时的for(int i=0;i<list.size();i++){try {int resultStatus = list.get(i).get();if(resultStatus == 0){//发送成功
                    ai.incrementAndGet();}} catch (Exception e) {e.printStackTrace();} }System.out.println("发送消息结束，耗时："+(System.nanoTime()-begin)/1000_000d);return ai.get();}public static void main(String[] args){PublishMsgTest pmt = new PublishMsgTest();//待接收人List<Integer> receivers = new ArrayList<Integer>();for(int i=0;i<1000;i++){receivers.add(i);}String content = "群发消息_测试代码";int successCount = pmt.sendMsg(receivers, content);System.out.println("共有【"+receivers.size()+"】接收者，发送成功【"+successCount+"】");}//完成发送消息private int sendMsg(Integer receiver, String content) {if(receiver%2 == 0){//模拟被2整除，即为发送成功return 0;}return 1;}

-----------------------14.786889-----------------------
接收者【2】,发送结果【0】
接收者【3】,发送结果【1】
接收者【4】,发送结果【0】
接收者【0】,发送结果【0】
接收者【6】,发送结果【0】
接收者【7】,发送结果【1】
接收者【1】,发送结果【1】
接收者【5】,发送结果【1】
接收者【10】,发送结果【0】
.
.
.
.
接收者【994】,发送结果【0】
接收者【993】,发送结果【1】
接收者【992】,发送结果【0】
接收者【996】,发送结果【0】
接收者【999】,发送结果【1】
接收者【998】,发送结果【0】
接收者【997】,发送结果【1】
发送消息结束，耗时：2033.053433
共有【1000】接收者，发送成功【500】