ensureThreadStarted() — netty Function Reference

Architecture documentation for the ensureThreadStarted() function in SingleThreadEventExecutor.java from the netty codebase.

Function java CommonUtil Concurrent calls 1 called by 1

Entity Profile

CommonUtil→ Concurrent→ ensureThreadStarted() — netty Function Reference

Dependency Diagram

graph TD
  a492b7bc_add7_4389_0b97_074f0f1429af["ensureThreadStarted()"]
  c9189467_acbc_07ea_3a8c_fecfe22ec122["SingleThreadEventExecutor"]
  a492b7bc_add7_4389_0b97_074f0f1429af -->|defined in| c9189467_acbc_07ea_3a8c_fecfe22ec122
  3883639c_b779_4c47_6f43_da56209b65a2["shutdown0()"]
  3883639c_b779_4c47_6f43_da56209b65a2 -->|calls| a492b7bc_add7_4389_0b97_074f0f1429af
  8eb7fcd3_fddd_aede_4b6c_2483c2c54021["doStartThread()"]
  a492b7bc_add7_4389_0b97_074f0f1429af -->|calls| 8eb7fcd3_fddd_aede_4b6c_2483c2c54021
  style a492b7bc_add7_4389_0b97_074f0f1429af fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/concurrent/SingleThreadEventExecutor.java lines 1160–1176

    private boolean ensureThreadStarted(int oldState) {
        if (oldState == ST_NOT_STARTED || oldState == ST_SUSPENDED) {
            try {
                doStartThread();
            } catch (Throwable cause) {
                STATE_UPDATER.set(this, ST_TERMINATED);
                terminationFuture.tryFailure(cause);

                if (!(cause instanceof Exception)) {
                    // Also rethrow as it may be an OOME for example
                    PlatformDependent.throwException(cause);
                }
                return true;
            }
        }
        return false;
    }