关注
import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.util.concurrent.ArrayBlockingQueue;import java.util.concurrent.BlockingQueue;import java.util.concurrent.CountDownLatch;import java.util.concurrent.atomic.AtomicInteger;public class Main22 { private static AtomicInteger count = new AtomicInteger(0); private static final int THREAD_COUNT = 3; public static void main(String[] args) throws IOException, InterruptedException { BufferedReader br = new BufferedReader(new InputStreamReader(System.in)); String line = null; // Scanner scan = new Scanner(System.in); BlockingQueue<String> bq = new ArrayBlockingQueue<>(200009); while ((line = br.readLine()) != null) { if ("".equals(line)) break; bq.put(line); } bq.add("__QUIT__"); bq.add("__QUIT__"); bq.add("__QUIT__"); CountDownLatch cdl = new CountDownLatch(THREAD_COUNT); Runnable task = new Runnable() { public void run() { while (true) { try { String str = bq.take(); if("__QUIT__".equals(str)){ cdl.countDown(); break; } if (str.contains("u51")) { count.incrementAndGet(); } } catch (InterruptedException e) { throw new RuntimeException(e); } } } }; Thread[] threads = new Thread[THREAD_COUNT]; for (int i = 0; i < THREAD_COUNT; i++) { threads[i] = new Thread(task); threads[i].start(); } cdl.await(); System.out.println(count.get()); }}
查看原帖
点赞 评论
相关推荐
06-26 22:20
门头沟学院 Java 点赞 评论 收藏
分享
07-09 15:55
门头沟学院 Java 点赞 评论 收藏
分享
牛客热帖
更多
正在热议
更多
# 实习生的蛐蛐区 #
30845次浏览 224人参与
# 面试官是我前女友 #
106174次浏览 722人参与
# 计算机有哪些岗位值得去? #
10441次浏览 95人参与
# 说说你知道的学历厂 #
21983次浏览 134人参与
# 应届生,你找到工作了吗 #
16275次浏览 135人参与
# 你找工作的时候用AI吗? #
12419次浏览 135人参与
# 面试尴尬现场 #
18154次浏览 113人参与
# 电网笔面经互助 #
36079次浏览 351人参与
# 社会教会你的第一课 #
23972次浏览 300人参与
# 下班后的时间你怎么安排 #
5854次浏览 65人参与
# 哪一瞬间觉得自己长大了 #
5912次浏览 112人参与
# 你认为小厂实习有用吗? #
8693次浏览 92人参与
# 学历贬值真的很严重吗? #
21818次浏览 161人参与
# 职场中对你有帮助的书 #
17445次浏览 203人参与
# 简历当中有水分算不算造假? #
20653次浏览 245人参与
# 双非应该如何逆袭? #
188150次浏览 3408人参与
# 神州信息工作体验 #
15711次浏览 67人参与
# 哪些公司校招卡第一学历 #
61963次浏览 234人参与
# 现在前端的就业环境真的很差吗 #
294802次浏览 3571人参与
# 毕业旅行去哪玩儿 #
12336次浏览 133人参与