task.nextExecuteNanoTime = -1L
    val queue = task.queue!!
    queue.futureTasks.remove(task)
    readyQueues.remove(queue)
    queue.activeTask = task
    busyQueues.add(queue)
  }

  private fun afterRun(
    task: Task,
    delayNanos: Long,
    completedNormally: Boolean,
  ) {
    assertLockHeld()

    val queue = task.queue!!
    check(queue.activeTask === task)

        }
        source = source.replaceAll(Pattern.quote("${fess.dictionary.path}"), dictionaryPath)//
                .replaceAll(Pattern.quote("${fess.index.codec}"), fessConfig.getIndexCodec())//
                .replaceAll(Pattern.quote("${fess.index.number_of_shards}"), numberOfShards)//
                .replaceAll(Pattern.quote("${fess.index.auto_expand_replicas}"), autoExpandReplicas);

                logger.warn("Failed to process shutdown task.", e);
            }
        });
    }

    /**
     * Gets the username of the current user.
     *
     * @return The username, or "guest" if not logged in.
     */
    public String getUsername() {
        return getRequestManager().findUserBean(FessUserBean.class).map(FessUserBean::getUserId).orElse(Constants.GUEST_USER);
    }

    /**