Skip to content

awaitable-hash-map.ru.md

Latest commit

 

History

History
82 lines (62 loc) · 3.83 KB

awaitable-hash-map.ru.md

File metadata and controls

82 lines (62 loc) · 3.83 KB

AwaitableHashMap

Обстоятельство

  • Есть пары ключ-значение, которые необходимо организовать в виде хэш-таблицы.
  • Ключи добавляются/удаляются в/из хэш-таблицу асинхронно.
  • Есть необходимость дождаться добавления/удаления некоторого ключа, чтобы продолжить асинхронный процесс.

Использование

Использование класса AwaitableHashMap лучше описать на примере.

Представьте, что вы реализуете клиент для Docker. Создание и удаление контейнеров тяжелые и долгие операции, поэтому вы решили выполнять их асинхронно. Каждый контейнер имеет уникальное имя и описывается классом Container.

class Container {
    CompletableFuture<Void> start();
    CompletableFuture<Void> stop();
    CompletableFuture<CommandResult> execute(String command);
    ...
}

Для удобства вы решили отслеживать все существующие контейнеры, используя AwaitableHashMap.

var containers = new AwaitableHashMap<String, Container>();

Добавление значений

Сразу, как только контейнер создан и подготовлен к использованию, добавьте его в список containers.

void createContainer(String name, String image) {
    var container = new Container(name, image);
    ...
    containers.put(name, container);
}

Ожидание значений

Вы можете взаимодействовать с контейнером сразу, как только он станет доступен. Предположим, вы собираетесь выполнить shell-команду. Для доступа к контейнеру просто запросите его по имени, используя метод await(), возвращающий экземпляр CompletableFuture<Container>. Ожидая результат, вы получите экземпляр Container запрашиваемого контейнера и сможете взаимодействовать с ним.

var commandResult = containers.await("my-debian")
        .thenCompose(container -> container
                .execute("echo Hello World!"));

Удаление значений

Сразу, как только контейнер удален, удалите его из списка containers.

void deleteContainer(String name) {
    var container = containers.get(name);
    ...
    containers.remove(name);
}

Ожидание удаления

Вы можете освободить какие-то ресурсы, связанные с контейнером, сразу, как только он удаляется. Предположим вам нужно удалить все связанные с контейнером тома. Для ожидания удаления используйте метод awaitRemove(), возвращающий экземпляр CompletableFuture<Boolean>. Ожидая результат, вы получите признак, был ли удален контейнер в действительности.

containers.awaitRemove(containerName)
        .thenAccept(success -> {
            if (success) {
                volumes.removeRelated(containerName);
            }
        });