EngineGP/system/library/cron/control_threads.php

<?php
if (!DEFINED('EGP'))
    exit(header('Refresh: 0; URL=http://' . $_SERVER['HTTP_HOST'] . '/404'));

class control_threads extends cron
{
    function __construct()
    {
        global $sql, $cfg, $argv;

        $aUnit = array();
        $sql->query('SELECT `id` FROM `control` ORDER BY `id` ASC');

        if (!$sql->num())
            return NULL;

        while ($unit = $sql->get())
            $aUnit[$unit['id']] = '';

        $sql->query('SELECT `id` FROM `control_servers` LIMIT 1');

        if (!$sql->num())
            return NULL;

        $sql->query('SELECT `id`, `unit`, `game` FROM `control_servers` ORDER BY `unit` DESC');

        $all = $sql->num();

        while ($server = $sql->get())
            $aUnit[$server['unit']][$server['game']] .= $server['id'] . ' ';

        if ($argv[3] == 'control_scan_servers_route')
            cron::$seping = 50;

        foreach ($aUnit as $unit => $aGame) {
            foreach ($aGame as $game => $servers) {
                $aData = explode(' ', $servers);

                $num = count($aData) - 1;
                $sep = $num > 0 ? ceil($num / cron::$seping) : 1;

                unset($aData[end($aData)]);

                $threads[] = cron::thread($sep, $game . ' ' . $unit, $aData);
            }
        }

        $cmd = '';

        foreach ($threads as $thread) {
            foreach ($thread as $screen => $servers)
                $cmd .= 'sudo -u www-data screen -dmS scan_' . (sys::first(explode(' ', $servers))) . '_' . $screen . ' taskset -c ' . $cfg['cron_taskset'] . ' sh -c \"cd /var/enginegp; php cron.php ' . $cfg['cron_key'] . ' ' . $argv[3] . ' ' . $servers . '\"; sleep 1;';
        }

        exec('screen -dmS control_threads_' . date('His', $start_point) . ' sh -c "' . $cmd . '"');

        return NULL;
    }
}

?>