PHP后台进程/异步处理的用法及在Drupal中的应用

/**
 * @param array $callback_params {'callback' : [name], 'params' : [args]}
 * @return type 
 */
function drupal_background_process($callback_params) {
  $cid = "drupal_background_" . time();
  cache_set($cid, $callback_params);
 
  $php =  dirname($_SERVER['SCRIPT_FILENAME']) . '/index_bg.php';
  pclose(popen("php $php $cid > /dev/null &", 'r'));
 
  return true;
}
 
//Log
function drupal_background_log($txt) {
  global $conf;
 
  $log = isset($conf['background_log']) ? $conf['background_log'] : '/tmp/drupal-background.log';
  if (isset($conf['background_log_enable']) && $conf['background_log_enable']) {
    file_put_contents($log, "\n" . $txt, FILE_APPEND);
  }
}

//bootstrap file
//make sure current directory is drupal base especiall command line
chdir(dirname(__FILE__));
 
require_once './includes/bootstrap.inc';
drupal_bootstrap(DRUPAL_BOOTSTRAP_FULL);
 
global $conf;
$conf['background_log_enable'] = TRUE;
 
if ($argc > 1) {
  $cid = $argv[1];
}
elseif (isset($_GET['cid'])){
  $cid = $_GET['cid'];
}
 
drupal_background_log(">>>$cid");
 
if ($cache = cache_get($cid)) {
  $object = (object)$cache->data;
 
  //drupal_background_log("DATA:\n" . serialize($cache->data));
 
  if (isset($object->callback)) {
    if (!isset($object->params) || !is_array($object->params)) {
      $object->params = array($object);
    }
 
    //Log and check if the 1st and second arguments are correct
    drupal_background_log('Execute: ' . $object->callback);
 
    call_user_func_array($object->callback, $object->params);
  }
 
  cache_clear_all($cid);
}
else {
  drupal_background_log("NOT FOUND CID \n");
}
 
drupal_background_log("DONE\n");

drupal_background_process(array('callback' => 'function_name', 'params' => array(1,2)));