Многопоточный HTML Парсер

public class AppGUI {
 
    private JFrame myFrame;
    private JPanel myPanel;
    private JPanel btnPanel;
    private JButton btnParse;
    private JTextField urlTextField;
    private JTextArea outcomeTextArea;
    private JScrollPane outcomeScroll;
    
    private HTMLParser parser = new HTMLParser();
    
    private Set<String> allLinks;
    private String host;
    private static final int THREADS_COUNT = 10;
    
    //private ExecutorService executor;
    private static TPExecutor executor;
    private Lock lock = new ReentrantLock();
    
    public void createGUI() {
        myFrame = new JFrame();
        myFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        myFrame.setSize(400,400);
        
        btnPanel = new JPanel();
        
        btnParse = new JButton("Parse");
        btnParse.addActionListener(new ButtonClickListener());
        btnPanel.add(btnParse);
        
        myPanel = new JPanel(new BorderLayout());
        myPanel.add(btnPanel, BorderLayout.SOUTH);
        
        urlTextField = new JTextField();
        myPanel.add(urlTextField, BorderLayout.NORTH);
        urlTextField.setText("http://www.nmu.org.ua/ua/");
        
        outcomeTextArea = new JTextArea();
        
        outcomeScroll = new JScrollPane(outcomeTextArea);
        outcomeScroll.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS);
        outcomeScroll.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_AS_NEEDED);
        myPanel.add(outcomeScroll, BorderLayout.CENTER);
        
        myFrame.getContentPane().add(myPanel);
        myFrame.setVisible(true);
    }
    
    public String getHost (URL page){
        String host = page.getHost().toLowerCase();
        if (host.startsWith("www.")){
            host = host.substring("www.".length());
        }
        return host;
    }
    
    class ButtonClickListener implements ActionListener {
        @Override
        public void actionPerformed(ActionEvent arg0) {
            if (btnParse.getText().equals("Parse")){
                outcomeTextArea.setText("");
                allLinks = new LinkedHashSet<>();
                allLinks.add(urlTextField.getText());
                //executor = Executors.newFixedThreadPool(10);
                executor = new TPExecutor(THREADS_COUNT, THREADS_COUNT, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>());
                try {
                    URL url = new URL(urlTextField.getText());
                    host = getHost(url);
                    executor.setStartTime(System.currentTimeMillis());
                    outcomeTextArea.append("Parsing started...\n\n");
                    executor.execute(new MyRunnable(url, host));
                    btnParse.setText("Stop");
                } catch (MalformedURLException e) {
                    e.printStackTrace();
                    JOptionPane.showMessageDialog(myFrame, "Invalid URL","Error", JOptionPane.OK_OPTION);
                }
                //executer.shutdown() блокирует создание новых задачь, ждет завершения активных задач и отрубает пул.
                //а нужно чтобы ждало завершения активных задач без блокирования создания новых.
            } else
            if (btnParse.getText().equals("Stop")){
                executor.shutdownNow();
                btnParse.setText("Parse");
            }
        }
    }
    
    class TPExecutor extends ThreadPoolExecutor{
 
        private long startTime;
        
        public TPExecutor(int corePoolSize, int maximumPoolSize,
                long keepAliveTime, TimeUnit unit,
                BlockingQueue<Runnable> workQueue) {
            super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
        }
        
        public void setStartTime(long startTime) {
            this.startTime = startTime;
        }
        
        @Override
        protected void terminated() { 
                outcomeTextArea.append("Parsing completed. Total time: "    + (System.currentTimeMillis() - startTime) / 1000 + " sec.");
        }
    }
    
    class MyRunnable implements Runnable{
        
        URL url;
        String host;
        
        public MyRunnable(URL url, String host){
            this.url = url;
            this.host = host;
        }
 
        @Override
        public void run() {
            try {
                Set<String> emails = parser.getEmails(url);
                if (!emails.isEmpty()){
                    lock.lock();
                    try{
                        outcomeTextArea.append(url.toString()+"\n");
                        for (String e:emails){
                            outcomeTextArea.append(e+"\n");
                        }
                        outcomeTextArea.append("\n");
                    }
                    finally {lock.unlock();}
                }
                Set<String> links = parser.getLinks(url, host);
                for (String l:links){
                    if(allLinks.add(l) == true){
                        executor.execute(new MyRunnable(new URL(l), host));
                    };
                }
            } catch (IOException | BadLocationException e) {
                e.printStackTrace();
            }
            
        }
        
    }
    
}