@Override
public void run() {
    try {
        while (true) {
            List<SimpleContent> docs = queue.take();
            ...
        }
    }
}

public static void main(String[] args) {
    for (QueueProps queueProps : queues) {
        BlockingQueue<List<SimpleContent>> blockingQueue = new ArrayBlockingQueue(1);
        QueuePerformer queuePerformer = new QueuePerformer(blockingQueue);
        queuePerformer.setName(queueProps.getQueueSuffix());
        queuePerformer.start();
        QueueSender queueSender = new QueueSender(blockingQueue);
        queueSender.setName(queueProps.getQueueSuffix());
        queueSender.start();
    }

    setTime();
    //и так далее......
}

queuePerformer.join();
queueSender.join();

public static void main(String[] args) throws InterruptedException {
    ExecutorService executorService = Executors.newFixedThreadPool(10);

    List<Callable<String>> todo = new ArrayList<>();

    for (int i = 0; i < 10; i++) {
        todo.add(new Task());
    }
    List<Future<String>> results = executorService.invokeAll(todo);
    System.out.println("Finished...");
}

static class Task implements Callable<String> {

    @Override
    public String call() throws Exception {
        Thread.sleep(5000);
        System.out.println(Thread.currentThread().getName() + " finished.");
        return "some-data";
    }
}

Executors.callable(new Task());