private final ConcurrentHashMap<String, Queue<Task>> taskMap = new ConcurrentHashMap<>();

        public void execute(Task task) {
            taskMap.compute(task.getKey(), (key, queue) -> {
                if (queue == null) {
                    // это первая таска с ключом, создаем очередь для тех кто пожелает присоседится 
                    // пока текущая таска в прогрессе
                    queue = new LinkedList<>();
                    poolExecutor.execute(new DecoratedTask(task));
                    return queue;
                } else {
                    queue.add(task);
                    // возвращаем ту же очередь, маппинг остается нетронутым, новый узел не аллоцируюется
                    return queue;
                }
            });
        }

        private class DecoratedTask implements Runnable {
            private final Task target;

            public DecoratedTask(Task target) {
                this.target = target;
            }

            @Override
            public void run() {
                try {
                    target.run();
                } finally {
                    taskMap.compute(target.getKey(), (key, queue) -> {
                        Task nextTask = queue.poll();
                        if (nextTask == null) {
                            // ждущих тасок по этому же ключу нет просто удаляем узел из мапы
                            return null;
                        }
                        try {
                            poolExecutor.execute(new DecoratedTask(nextTask));
                        } finally {
                            return queue;
                        }
                    });
                }
            }
        }