java SwingWorker запускает runnables из doInBackground() и как уведомить поток отправки событий

Документы SwingWorker довольно ясны. Вы должны создать подкласс SwingWorker и выполнить длинную задачу в методе doInBackground(). Вы должны обновить пользовательский интерфейс в методе done().

Это действительно так просто.

Изменить:
чтобы было понятнее. Предполагая, что ваш класс Connection расширяет SwingWorker, ему нет необходимости реализовывать Runnable, и вам не нужно явно предоставлять пул потоков для запуска рабочих процессов. Просто поместите содержимое run() метод в doInBackground().

Теперь ваш основной цикл выглядит примерно так:

while (true) {
  Socket client_socket = listen_socket.accept();
  Connection con = new Connection(client_socket, "name");
  con.execute();
}

Кажется, вы подчиняетесь ExecutorService в своем основном цикле. Есть ли для этого конкретная причина (обратите внимание, что SwingWorker управляет собственным внутренним ThreadPoolExecutor для рабочих потоков). Это для ограничения количества одновременных клиентов? Если это так, есть другие способы сделать это.

Я бы пошел на следующее: иметь потокобезопасную очередь блокировки или список в родительском потоке, который будет передан рабочим потокам. После выполнения задачи рабочий поток отправит сообщение, содержащее идентификатор записи результата, в эту очередь блокировки. Родительский поток заблокируется в очереди, ожидая результатов от дочерних потоков. Всякий раз, когда в очереди есть элемент, родительский поток возьмет его и получит эти данные из БД и отобразит их пользователю.

Я попытался создать пример SwingWorker, который генерирует фоновые рабочие потоки, результаты которых публикуются через фиксированный пул ExecutorService и CompletionService. У меня все еще есть некоторые вопросы, касающиеся безопасности потоков при создании рабочих потоков внутри одного потока и последующем вызове их фьючерсов внутри другого потока (фоновый поток SwingWorker).

Например:

import java.awt.BorderLayout;
import java.awt.event.ActionEvent;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.CompletionService;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorCompletionService;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

import javax.swing.*;

@SuppressWarnings("serial")
public class TestSwingWorker extends JPanel {
   public static final int POOL_SIZE = 4;
   private JTextArea tArea = new JTextArea(10, 30);
   private JButton doItBtn;

   public TestSwingWorker() {
      doItBtn = new JButton(new AbstractAction("Do It!") {
         public void actionPerformed(ActionEvent ae) {
            swingWorkerRunning(true);
            MySwingWorker mySW = new MySwingWorker();
            mySW.execute();
            tArea.append("SwingWorker started\n");
         }
      });
      JPanel btnPanel = new JPanel();
      btnPanel.add(doItBtn);
      tArea.setEditable(false);
      tArea.setFocusable(false);

      setLayout(new BorderLayout());
      add(new JScrollPane(tArea), BorderLayout.CENTER);
      add(btnPanel, BorderLayout.SOUTH);
   }

   private class MySwingWorker extends SwingWorker<String, String> {
      @Override
      protected String doInBackground() throws Exception {
         ExecutorService execService = Executors.newFixedThreadPool(POOL_SIZE);
         final CompletionService<String> completionService = new ExecutorCompletionService<String>(
               execService);
         new Thread(new Runnable() {

            @Override
            public void run() {
               for (int i = 0; i < POOL_SIZE; i++) {
                  final int index = i;
                  completionService.submit(new Callable<String>() {
                     public String call() throws Exception {
                        Thread.sleep(2000 * index + 500);
                        return "Callable " + index + " complete";
                     }
                  });
                  try {
                     Thread.sleep(1000);
                  } catch (InterruptedException e) {
                  }
               }
            }
         }).start();

         for (int i = 0; i < POOL_SIZE; i++) {
            Future<String> f = completionService.take();
            publish(f.get());
         }

         return "Do in background done";
      }

      @Override
      protected void process(List<String> chunks) {
         for (String chunk : chunks) {
            tArea.append(chunk + "\n");
         }
      }

      @Override
      protected void done() {
         try {
            tArea.append(get() + "\n");
         } catch (InterruptedException e) {
            e.printStackTrace();
         } catch (ExecutionException e) {
            e.printStackTrace();
         } finally {
            swingWorkerRunning(false);
         }
      }
   }

   public void swingWorkerRunning(boolean running) {
      doItBtn.setEnabled(!running);
   }

   private static void createAndShowGui() {
      TestSwingWorker mainPanel = new TestSwingWorker();

      JFrame frame = new JFrame("TestSwingWorker");
      frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
      frame.getContentPane().add(mainPanel);
      frame.pack();
      frame.setLocationByPlatform(true);
      frame.setVisible(true);
   }

   public static void main(String[] args) {
      SwingUtilities.invokeLater(new Runnable() {
         public void run() {
            createAndShowGui();
         }
      });
   }
}

Поправки приветствуются!