code: @SuppressWarnings("unchecked")
      public void runDeadlockFuture(Runnable deadlockGuardTask) {
          if (deadlockFuture == null) {
              ThreadPoolTaskScheduler deadlockGuard = conn.getDeadlockGuardScheduler();
              if (deadlockGuard != null) {
                  try {
                      deadlockFuture = (ScheduledFuture<Runnable>) deadlockGuard.schedule(deadlockGuardTask, new Date(packet.getExpirationTime()));
                  } catch (TaskRejectedException e) {
                      log.warn("DeadlockGuard task is rejected for {}", sessionId, e);
                  }
              } else {
                  log.debug("Deadlock guard is null for {}", sessionId);
              }
          } else {
              log.warn("Deadlock future is already create for {}", sessionId);
          }
      }
docs: Runs deadlock guard task
  
  @param deadlockGuardTask
  deadlock guard task