fetchWatchees() — netty Function Reference

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

Function java CommonUtil Concurrent called by 1

Entity Profile

CommonUtil→ Concurrent→ fetchWatchees() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

common/src/main/java/io/netty/util/ThreadDeathWatcher.java lines 197–210

        private void fetchWatchees() {
            for (;;) {
                Entry e = pendingEntries.poll();
                if (e == null) {
                    break;
                }

                if (e.isWatch) {
                    watchees.add(e);
                } else {
                    watchees.remove(e);
                }
            }
        }