awaitUninterruptibly() — netty Function Reference

Architecture documentation for the awaitUninterruptibly() function in DefaultPromise.java from the netty codebase.

Function java CommonUtil Concurrent calls 5 called by 1

Entity Profile

CommonUtil→ Concurrent→ awaitUninterruptibly() — netty Function Reference

Dependency Diagram

graph TD
  468882d3_22d8_7166_9c69_b2be03be150b["awaitUninterruptibly()"]
  a0080a71_f091_42e0_8a20_424f0bf9d34a["DefaultPromise"]
  468882d3_22d8_7166_9c69_b2be03be150b -->|defined in| a0080a71_f091_42e0_8a20_424f0bf9d34a
  9268e1f1_ed1a_2eec_4c48_bcd5c24473d1["syncUninterruptibly()"]
  9268e1f1_ed1a_2eec_4c48_bcd5c24473d1 -->|calls| 468882d3_22d8_7166_9c69_b2be03be150b
  3740273d_6083_b014_4154_fce4202c359c["isDone()"]
  468882d3_22d8_7166_9c69_b2be03be150b -->|calls| 3740273d_6083_b014_4154_fce4202c359c
  60509b5d_40ce_2ffb_3446_bc55883f645e["checkDeadLock()"]
  468882d3_22d8_7166_9c69_b2be03be150b -->|calls| 60509b5d_40ce_2ffb_3446_bc55883f645e
  840a82ca_e064_c245_c313_71d5cad7b138["incWaiters()"]
  468882d3_22d8_7166_9c69_b2be03be150b -->|calls| 840a82ca_e064_c245_c313_71d5cad7b138
  eeeb5e2c_469b_65b8_2532_243d417749c2["decWaiters()"]
  468882d3_22d8_7166_9c69_b2be03be150b -->|calls| eeeb5e2c_469b_65b8_2532_243d417749c2
  93f49b0e_0a57_4979_d91e_7cad339bdb09["await0()"]
  468882d3_22d8_7166_9c69_b2be03be150b -->|calls| 93f49b0e_0a57_4979_d91e_7cad339bdb09
  style 468882d3_22d8_7166_9c69_b2be03be150b fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/concurrent/DefaultPromise.java lines 277–305

    @Override
    public Promise<V> awaitUninterruptibly() {
        if (isDone()) {
            return this;
        }

        checkDeadLock();

        boolean interrupted = false;
        synchronized (this) {
            while (!isDone()) {
                incWaiters();
                try {
                    wait();
                } catch (InterruptedException e) {
                    // Interrupted while waiting.
                    interrupted = true;
                } finally {
                    decWaiters();
                }
            }
        }

        if (interrupted) {
            Thread.currentThread().interrupt();
        }

        return this;
    }