Java wątki, ExecutorService

main(){
ExecutorService specialService = Executors.newFixedThreadPool(2);

        specialService.submit(() -> {
            while (!isEndOfDayWork || anyTaskLeft) {
                Employee employee = removeFromQueue();
                if (employee != null) {
                    handleSpecialStatusPriorityClient(employee);
                    }}});
}

private void handleSpecialStatusPriorityClient(Employee employee){
        Client specialStatusClient = specialStatusClients.poll();
        handleTheQuestion(specialStatusClient, employee);

        employeesLock.lock();
        try{
            employees.add(employee);
        }finally {
            employeesLock.unlock();
        }
    }


    private void handleTheQuestion(Client handledClient, Employee employee){
        if(handledClient!=null) {
            final long time = handledClient.getQuestion().getAmountOfTimeToHandleQuestion();
            try {
                Thread.sleep(time * 1000);
                System.out.println(employee.getID() + " just handled "+ handledClient.getQuestion() + " task!");
            } catch (InterruptedException e) {
                System.out.println("Problem during thread sleeping");
            }
        }
    }

ExecutorService specialService = Executors.newFixedThreadPool(2);


ExecutorService specialService1 = Executors.newFixedThreadPool(1);
ExecutorService specialService2 = Executors.newFixedThreadPool(1);