schedule() — netty Function Reference

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

Function java CommonUtil Logging calls 2 called by 2

Entity Profile

CommonUtil→ Logging→ schedule() — netty Function Reference

Dependency Diagram

graph TD
  52d983df_3c33_cc34_17dc_62af3798f3ef["schedule()"]
  a874767f_1376_f502_6409_38219e3d70ef["ThreadDeathWatcher"]
  52d983df_3c33_cc34_17dc_62af3798f3ef -->|defined in| a874767f_1376_f502_6409_38219e3d70ef
  d0ccf1bb_8ca7_fdeb_a3d1_eecc0fd357d4["watch()"]
  d0ccf1bb_8ca7_fdeb_a3d1_eecc0fd357d4 -->|calls| 52d983df_3c33_cc34_17dc_62af3798f3ef
  bcd89545_0ae1_7935_4b1c_1e03947be6b7["unwatch()"]
  bcd89545_0ae1_7935_4b1c_1e03947be6b7 -->|calls| 52d983df_3c33_cc34_17dc_62af3798f3ef
  ea438268_ec3e_4365_a5a4_45d5e1932d08["Entry()"]
  52d983df_3c33_cc34_17dc_62af3798f3ef -->|calls| ea438268_ec3e_4365_a5a4_45d5e1932d08
  2e12d8f3_2a76_c115_2e1f_27af3c853d54["run()"]
  52d983df_3c33_cc34_17dc_62af3798f3ef -->|calls| 2e12d8f3_2a76_c115_2e1f_27af3c853d54
  style 52d983df_3c33_cc34_17dc_62af3798f3ef fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/ThreadDeathWatcher.java lines 100–121

    private static void schedule(Thread thread, Runnable task, boolean isWatch) {
        pendingEntries.add(new Entry(thread, task, isWatch));

        if (started.compareAndSet(false, true)) {
            final Thread watcherThread = threadFactory.newThread(watcher);
            // Set to null to ensure we not create classloader leaks by holds a strong reference to the inherited
            // classloader.
            // See:
            // - https://github.com/netty/netty/issues/7290
            // - https://bugs.openjdk.java.net/browse/JDK-7008595
            AccessController.doPrivileged(new PrivilegedAction<Void>() {
                @Override
                public Void run() {
                    watcherThread.setContextClassLoader(null);
                    return null;
                }
            });

            watcherThread.start();
            ThreadDeathWatcher.watcherThread = watcherThread;
        }
    }