import java.util.Scanner; import java.util.concurrent.BlockingQueue; import java.util.concurrent.CountDownLatch; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.atomic.AtomicInteger; //消费者 class Task implements Runnable {     private final CountDownLatch startGate;     private final CountDownLatch endGate;     private final BlockingQueue<String> queue;     private final AtomicInteger count;     Task(CountDownLatch startGate, CountDownLatch endGate, BlockingQueue<String> queue, AtomicInteger count) {         this.startGate = startGate;         this.endGate = endGate;         this.queue = queue;         this.count = count;     }     @Override     public void run() {         try {             startGate.await();             while (!queue.isEmpty()) {                 try {                     if (queue.take().contains("u51")) {                         count.incrementAndGet();                     }                 } finally {                     endGate.countDown();                 }             }         } catch (InterruptedException e) {             e.printStackTrace();         }     } } public class Main {     public static void main(String[] args) throws InterruptedException {         final BlockingQueue<String> queue = new LinkedBlockingQueue<>();         final AtomicInteger count = new AtomicInteger();         Scanner scanner = new Scanner(System.in);         //闭锁         final CountDownLatch startGate = new CountDownLatch(1);         final CountDownLatch endGate = new CountDownLatch(3);         while (scanner.hasNextLine()) {             queue.put(scanner.nextLine());         }         Task task = new Task(startGate, endGate, queue, count);         new Thread(task).start();         new Thread(task).start();         new Thread(task).start();         startGate.countDown();         endGate.await();         System.out.println(count);     } } 请教一下这样可以吗？因为没有原题也没法测了