Na}{

File Content: `ActionScheduler_AsyncRequest_QueueRunner.php`

<?php

defined( 'ABSPATH' ) || exit;

/**
 * ActionScheduler_AsyncRequest_QueueRunner class.
 */
class ActionScheduler_AsyncRequest_QueueRunner extends WP_Async_Request {

	/**
	 * Data store for querying actions
	 *
	 * @var ActionScheduler_Store
	 */
	protected $store;

	/**
	 * Prefix for ajax hooks
	 *
	 * @var string
	 */
	protected $prefix = 'as';

	/**
	 * Action for ajax hooks
	 *
	 * @var string
	 */
	protected $action = 'async_request_queue_runner';

	/**
	 * Initiate new async request.
	 *
	 * @param ActionScheduler_Store $store Store object.
	 */
	public function __construct( ActionScheduler_Store $store ) {
		parent::__construct();
		$this->store = $store;
	}

	/**
	 * Handle async requests
	 *
	 * Run a queue, and maybe dispatch another async request to run another queue
	 * if there are still pending actions after completing a queue in this request.
	 */
	protected function handle() {
		do_action( 'action_scheduler_run_queue', 'Async Request' ); // run a queue in the same way as WP Cron, but declare the Async Request context.

		$sleep_seconds = $this->get_sleep_seconds();

		if ( $sleep_seconds ) {
			sleep( $sleep_seconds );
		}

		$this->maybe_dispatch();
	}

	/**
	 * If the async request runner is needed and allowed to run, dispatch a request.
	 */
	public function maybe_dispatch() {
		if ( ! $this->allow() ) {
			return;
		}

		$this->dispatch();
		ActionScheduler_QueueRunner::instance()->unhook_dispatch_async_request();
	}

	/**
	 * Only allow async requests when needed.
	 *
	 * Also allow 3rd party code to disable running actions via async requests.
	 */
	protected function allow() {

		if ( ! has_action( 'action_scheduler_run_queue' ) || ActionScheduler::runner()->has_maximum_concurrent_batches() || ! $this->store->has_pending_actions_due() ) {
			$allow = false;
		} else {
			$allow = true;
		}

		return apply_filters( 'action_scheduler_allow_async_request_runner', $allow );
	}

	/**
	 * Chaining async requests can crash MySQL. A brief sleep call in PHP prevents that.
	 */
	protected function get_sleep_seconds() {
		return apply_filters( 'action_scheduler_async_request_sleep_seconds', 5, $this );
	}
}

Name	Size	Permission
WP_CLI	---	0755
abstracts	---	0755
actions	---	0755
data-stores	---	0755
migration	---	0755
schedules	---	0755
schema	---	0755
ActionScheduler_ActionClaim.php	652 bytes	0644
ActionScheduler_ActionFactory.php	16293 bytes	0644
ActionScheduler_AdminView.php	10492 bytes	0644
ActionScheduler_AsyncRequest_QueueRunner.php	2163 bytes	0644
ActionScheduler_Compatibility.php	3904 bytes	0644
ActionScheduler_DataController.php	5403 bytes	0644
ActionScheduler_DateTime.php	2060 bytes	0644
ActionScheduler_Exception.php	207 bytes	0644
ActionScheduler_FatalErrorMonitor.php	2565 bytes	0644
ActionScheduler_InvalidActionException.php	1477 bytes	0644
ActionScheduler_ListTable.php	21437 bytes	0644
ActionScheduler_LogEntry.php	1942 bytes	0644
ActionScheduler_NullLogEntry.php	330 bytes	0644
ActionScheduler_OptionLock.php	4076 bytes	0644
ActionScheduler_QueueCleaner.php	8066 bytes	0644
ActionScheduler_QueueRunner.php	9715 bytes	0644
ActionScheduler_SystemInformation.php	2497 bytes	0644
ActionScheduler_Versions.php	3690 bytes	0644
ActionScheduler_WPCommentCleaner.php	4519 bytes	0644
ActionScheduler_wcSystemStatus.php	5264 bytes	0644

File Content: ActionScheduler_AsyncRequest_QueueRunner.php

File Content: `ActionScheduler_AsyncRequest_QueueRunner.php`