processCancelledTasks() — netty Function Reference

Architecture documentation for the processCancelledTasks() function in HashedWheelTimer.java from the netty codebase.

Function java CommonUtil Logging calls 1 called by 1

Entity Profile

CommonUtil→ Logging→ processCancelledTasks() — netty Function Reference

Dependency Diagram

graph TD
  f4e4374f_cea1_44a1_d8cc_b9bc9e38ac91["processCancelledTasks()"]
  97b31b84_3527_3690_913b_44ff6fafb9cc["Worker"]
  f4e4374f_cea1_44a1_d8cc_b9bc9e38ac91 -->|defined in| 97b31b84_3527_3690_913b_44ff6fafb9cc
  ea613877_8294_fd85_27b0_0c4903842ef1["run()"]
  ea613877_8294_fd85_27b0_0c4903842ef1 -->|calls| f4e4374f_cea1_44a1_d8cc_b9bc9e38ac91
  50a46f24_2569_1284_1d49_ba6191429435["removeAfterCancellation()"]
  f4e4374f_cea1_44a1_d8cc_b9bc9e38ac91 -->|calls| 50a46f24_2569_1284_1d49_ba6191429435
  style f4e4374f_cea1_44a1_d8cc_b9bc9e38ac91 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/main/java/io/netty/util/HashedWheelTimer.java lines 547–562

        private void processCancelledTasks() {
            for (;;) {
                HashedWheelTimeout timeout = cancelledTimeouts.poll();
                if (timeout == null) {
                    // all processed
                    break;
                }
                try {
                    timeout.removeAfterCancellation();
                } catch (Throwable t) {
                    if (logger.isWarnEnabled()) {
                        logger.warn("An exception was thrown while process a cancellation task", t);
                    }
                }
            }
        }