따분한일상

<?php

error_reporting(E_ALL & ~E_NOTICE);

$fp = fopen(dirname(__FILE__).'/testdata.txt','w');

fputs($fp,"id,str100byte,date_type_date,int_type_date\n");

fclose($fp);

// 동시 실행 프로세스 수

$maxProcCount = getCpuCount();

//$maxProcCount += 2;

echo "Cpu count ". $maxProcCount."\n";

$i = 946684800;

$step = 3600*24;

echo ">>>". pcntl_waitpid(0, $status) ."\n";

for ( $j = 0 ; $j < $maxProcCount; $j++)

{

    makefile( $i );

    $i += $step;

}

while (pcntl_waitpid(0, $status) != -1) {

    //$status = pcntl_wexitstatus($status);

    if ( $i > 978307200 ) continue;

    // job 할당

    makefile($i);

    $i += $step;

}

function makefile($a)

{

        $pid = pcntl_fork();

    // error

    if ($pid == -1) {

        echo '[ERROR] could not fork'."\n";

        exit;

    }

    // child

    else if ($pid == 0) {

        // 단위계산 수행

        $startTime = microtime(true);

        $fp = fopen(dirname(__FILE__).'/testdata.txt','a');

        $end = $a + (3600*24); // 여기가 10으로 되어 있었네;;

//      echo "start .. " . gmdate("Y-m-d H:i:s", $a)."..\n";

        for ($i = $a; $i<$end ;$i+=1)

        {

                fprintf($fp,"null,\"%s\",\"%s\",%s\n",RandomString(100), gmdate("Y-m-d H:i:s", $i), $i);

                fprintf($fp,"null,\"%s\",\"%s\",%s\n",RandomString(100), gmdate("Y-m-d H:i:s", $i), $i);

                fprintf($fp,"null,\"%s\",\"%s\",%s\n",RandomString(100), gmdate("Y-m-d H:i:s", $i), $i);

                fprintf($fp,"null,\"%s\",\"%s\",%s\n",RandomString(100), gmdate("Y-m-d H:i:s", $i), $i);

                fprintf($fp,"null,\"%s\",\"%s\",%s\n",RandomString(100), gmdate("Y-m-d H:i:s", $i), $i);

                //fprintf($fp,"null,%s,%s,%s\n",RandomString(100), gmdate("Y-m-d H:i:s", $i), $i);

                if ( $i % 1000 == 0 )

                {

                        usleep(1);

                }

        }

        fclose($fp);

        printf("end .. %s, (%.3f sec)\n", gmdate("Y-m-d", $a) , microtime(true) - $startTime);

        exit;

    }

    // parent

    else {

    }

}

function RandomString($len = 10)

{

    $characters = '0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ';

    $randstring = '';

    $strlen = strlen($characters);

    for ($i = 0; $i < $len ; $i++) {

        $randstring .= $characters[rand(0, $strlen)];

    }

    return $randstring;

}

// CPU 프로세서 수 반환

function getCpuCount()

{

    return substr_count(file_get_contents('/proc/cpuinfo'), 'processor');

}