Drupal → Универсальная очередь для выполнения произвольных функций

/**
 * Implements hook_cron_queue_info().
 */
function modulename_cron_queue_info() {
  $queues['universal_queue'] = array(
    'worker callback' => 'modulename_universal_queue_callback',
  );
  return $queues;
}
 
/**
 * Universal queue worker callback.
 */
function modulename_universal_queue_callback($data) {
  if (isset($data['file'])) {
    include_once DRUPAL_ROOT . '/' . $data['file'];
  }
  call_user_func_array($data['function'], $data['arguments']);
}

/** @var SystemQueue $queue */
$queue = DrupalQueue::get('universal_queue');
 
// Отложенно удалить ноду
$queue->createItem(array(
  'function' => 'node_delete',
  'arguments' => array(
    'nid' => 123,
  ),
));
 
// Отложенно скачать файл
$queue->createItem(array(
  'function' => 'system_retrieve_file',
  'arguments' => array(
    'url' => 'http://img.yandex.net/i/www/logo.png',
    'destination' => 'public://image',
  ),
));
 
// Отложенно послать письмо
$queue->createItem(array(
  'function' => 'drupal_mail',
  'arguments' => array(
    'module' => 'system',
    'key' => 'mail',
    'to' => 'to@example.com',
    'language' => language_default(),
    'params' => array(
      'context' => array(
        'subject' => 'Some subject',
        'message' => 'Some message',
      ),
    ),
  ),
));