code: void add(EventQueue source) {
          while (true) {
              EventChannelsTuple entry = source.poll();
              if (entry == null) {
                  break;
              }
              entry.event.processedBy(this);
              queue.add(entry);
          }
          synchronized (this) {
              if (!isExecuting) {
                  GeneratorRegistry.instance().add(this);
                  isExecuting = true;
                  executorService.execute(this);
              }
          }
      }
docs: /* default