startThread() — netty Function Reference

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

Function java CommonUtil Concurrent calls 3 called by 1

Entity Profile

CommonUtil→ Concurrent→ startThread() — netty Function Reference

Dependency Diagram

graph TD
  2df06e90_ae68_2dbc_f754_10fc8d9ce8f6["startThread()"]
  c9189467_acbc_07ea_3a8c_fecfe22ec122["SingleThreadEventExecutor"]
  2df06e90_ae68_2dbc_f754_10fc8d9ce8f6 -->|defined in| c9189467_acbc_07ea_3a8c_fecfe22ec122
  ced7700b_627f_0ab1_ff34_9e3824dfeea8["execute()"]
  ced7700b_627f_0ab1_ff34_9e3824dfeea8 -->|calls| 2df06e90_ae68_2dbc_f754_10fc8d9ce8f6
  746a4041_9da7_c092_21aa_f3e66ecdea8e["resetIdleCycles()"]
  2df06e90_ae68_2dbc_f754_10fc8d9ce8f6 -->|calls| 746a4041_9da7_c092_21aa_f3e66ecdea8e
  a1a3b297_ac6f_d088_ac32_123a759e3181["resetBusyCycles()"]
  2df06e90_ae68_2dbc_f754_10fc8d9ce8f6 -->|calls| a1a3b297_ac6f_d088_ac32_123a759e3181
  8eb7fcd3_fddd_aede_4b6c_2483c2c54021["doStartThread()"]
  2df06e90_ae68_2dbc_f754_10fc8d9ce8f6 -->|calls| 8eb7fcd3_fddd_aede_4b6c_2483c2c54021
  style 2df06e90_ae68_2dbc_f754_10fc8d9ce8f6 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/concurrent/SingleThreadEventExecutor.java lines 1141–1158

    private void startThread() {
        int currentState = state;
        if (currentState == ST_NOT_STARTED || currentState == ST_SUSPENDED) {
            if (STATE_UPDATER.compareAndSet(this, currentState, ST_STARTED)) {
                resetIdleCycles();
                resetBusyCycles();
                boolean success = false;
                try {
                    doStartThread();
                    success = true;
                } finally {
                    if (!success) {
                        STATE_UPDATER.compareAndSet(this, ST_STARTED, ST_NOT_STARTED);
                    }
                }
            }
        }
    }