notifyWatchees() — netty Function Reference

Architecture documentation for the notifyWatchees() function in ThreadDeathWatcher.java from the netty codebase.

Function java CommonUtil Logging calls 1 called by 1

Entity Profile

CommonUtil→ Logging→ notifyWatchees() — netty Function Reference

Dependency Diagram

graph TD
  666cccad_fc12_bc19_59b3_051276b803c6["notifyWatchees()"]
  5f6d0707_3005_8256_7c2d_19661826552d["Watcher"]
  666cccad_fc12_bc19_59b3_051276b803c6 -->|defined in| 5f6d0707_3005_8256_7c2d_19661826552d
  2e12d8f3_2a76_c115_2e1f_27af3c853d54["run()"]
  2e12d8f3_2a76_c115_2e1f_27af3c853d54 -->|calls| 666cccad_fc12_bc19_59b3_051276b803c6
  2e12d8f3_2a76_c115_2e1f_27af3c853d54["run()"]
  666cccad_fc12_bc19_59b3_051276b803c6 -->|calls| 2e12d8f3_2a76_c115_2e1f_27af3c853d54
  style 666cccad_fc12_bc19_59b3_051276b803c6 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/ThreadDeathWatcher.java lines 212–227

        private void notifyWatchees() {
            List<Entry> watchees = this.watchees;
            for (int i = 0; i < watchees.size();) {
                Entry e = watchees.get(i);
                if (!e.thread.isAlive()) {
                    watchees.remove(i);
                    try {
                        e.task.run();
                    } catch (Throwable t) {
                        logger.warn("Thread death watcher task raised an exception:", t);
                    }
                } else {
                    i ++;
                }
            }
        }