docs: public synchronized void connect() {
      if(executor == null) {
        executor = new ThreadPoolExecutor(0, processors, 10L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>());
        executor.allowCoreThreadTimeOut(true);
      }
      if(++connected == 1) {
        executor.allowCoreThreadTimeOut(false);
        executor.setCorePoolSize(executor.getMaximumPoolSize());
      }
    }