用三个线程处理文件

Question

ExecutorService executor1 = Executors.newSingleThreadExecutor();
        ExecutorService executor2 = Executors.newSingleThreadExecutor();
        ExecutorService executor3 = Executors.newSingleThreadExecutor();
        ArrayBlockingQueue<String> abq = new ArrayBlockingQueue<String>(1000);
        try {

             String line;
             InputStream is = file.getInputStream();
             br = new BufferedReader(new InputStreamReader(is));
             while ((line = br.readLine()) != null) {
                 String[] values = line.split(",");
                 List<String> valuesList = Arrays.asList(values);
                 for(String valueList : valuesList) {
                     abq.put(valueList);
                     executor2.execute(new Runnable () {
                         public void run() {
                             System.out.println(valueList + Thread.currentThread().getName());
                         }
                     });       

1. 从主线程读取文件
2. 将读取值存储到blockingqueue中，另一个线程将从中访问和处理。
3. 有另一个线程要写入另一个文件。
   但我不知道如何做到这一点。如果我声明了一个fixedthreadpool，我将无法控制哪个线程执行什么操作，但在这种方法中，这是否类似于顺序处理，因为线程属于不同的池？
   如果有人能指导我如何执行此操作，这将对我有很大帮助。

Answer 1

我不知道我是否明白你想做什么，但我会这样做：我创建了3个线程并以不同的方式命名它们，根据名称，我让它们运行3种不同的方法：第一种方法读取文件，并将结果放在所有trheads共享的arraylist和静态的arraylist中；第二种方法有一个无限循环（或一个任务，如果您想做一些优化，则每隔一定时间运行一次），它总是获取arraylist的第一个元素，处理它，并将其放在另一个arraylist中，这也是共享的和静态的；第三个线程也有一个循环（或任务），它总是获取第一个元素，并将其打印到文件中。

我会这么做，但也许我不明白，如果你需要写信给我

（谷歌翻译从：意大利语到：英语）