1. PHP / Говнокод #5564

    +163

    1. 01
    2. 02
    3. 03
    4. 04
    5. 05
    6. 06
    7. 07
    8. 08
    9. 09
    10. 10
    11. 11
    12. 12
    13. 13
    14. 14
    15. 15
    16. 16
    17. 17
    18. 18
    19. 19
    20. 20
    21. 21
    22. 22
    23. 23
    24. 24
    25. 25
    26. 26
    27. 27
    28. 28
    29. 29
    30. 30
    31. 31
    32. 32
    33. 33
    34. 34
    35. 35
    36. 36
    37. 37
    38. 38
    39. 39
    40. 40
    41. 41
    42. 42
    43. 43
    44. 44
    45. 45
    46. 46
    47. 47
    48. 48
    49. 49
    50. 50
    51. 51
    52. 52
    53. 53
    54. 54
    55. 55
    56. 56
    57. 57
    58. 58
    59. 59
    60. 60
    61. 61
    62. 62
    63. 63
    64. 64
    65. 65
    66. 66
    67. 67
    68. 68
    69. 69
    70. 70
    71. 71
    72. 72
    73. 73
    74. 74
    75. 75
    76. 76
    <?
class Thread {
<...>
	function Thread($proc_id) {
		$this->db=new ezSQL_mssql(s_login, s_password, s_db_name_threads, s_host);
		$this->proc_id=$proc_id;
		$this->timeout=500;
		$this->last_busy=0;
		$this->notactive_num=0;
		$query="INSERT INTO threads(proc_id, last_beat) VALUES('".$this->proc_id."','".(time()+60)."');";
		$this->db->query($query);
	}
	static function Create($url,$proc_id) {
		$t = new Thread($proc_id);
		
		//### execute thread
		//NB!!!
		//BE CAREFUL WITH LOG PATHS, IF YOU MISS OR MISSPEL THE PATH, IT IS HARDLY POSSIBLE TO DEBUG
		//IF YOU MISSPELL THE PATH YOU CAN FACE THE PROBLEM OF THREADS SIMPLY DO NOT START OR DO NOT LOG WITHOUT ANY NOTIFICATION
		//USE YOUR OWN PATHS FOR PHP, LOGS AND COMMAND LINE COMMANDS AD PARAMETERS FOR YOUR SPECIFIC OS, WINDOWS EXAMPLE IS BELOW
		//start /B will execute background process in windows, > symbol will store the output of current process into log file
		//you can call threads from another server via http request etc.
		pclose(popen("start /B \"$proc_id\" C:\php\php.exe D:\wwwroot\\newimport\elko\import_ignitor_thread.php > D:\globalimport\logs\\".$proc_id.".txt $proc_id","r"));		
		
		//give some time to start the thread
		Sleeper(1000);
		return $t;
	}
	
	//check is Thread active or not
	//check active, busy, last beat etc.
	//you can put here your own business logic how thread should be checked for statused etc.
	function isActive () {
    if($this->state==3){
			return false;
		}elseif ($this->last_busy==1){
			return true;
		}
		$cur_time=time();
		if($cur_time>$this->last_beat){
			$result=$this->db->get_var("SELECT last_beat FROM threads WHERE proc_id=".$this->proc_id);
			$this->state=$this->db->get_var("SELECT state FROM threads WHERE proc_id=".$this->proc_id);
			if($cur_time<$result){
				return true;
			}
		}else{
			return true;
		}
		return true;
	}
	
	//check is Thread is busy or not, in order to give a new task/job
	//it is similat to the previous procedure
	function isBusy() {
		//$this->tell("ping"); - this could be implemented in the future
		$cur_time=time();
		if($cur_time>$this->last_beat or $this->last_busy==0){
			$result=$this->db->get_var("SELECT busy FROM threads WHERE proc_id=".$this->proc_id);
			$this->last_busy=$result;
			if($result==1){
				return true;
			}else{
				return false;
			}
		}else{
			return false;
		}
	}
	
	//tells a command to the thread
	function tell($thought, $params = NULL) {
		$param=base64_encode(serialize($params));
		$query="INSERT INTO cmd(proc_id, cmd, param) VALUES('".$this->proc_id."','".$thought."','".$param."');";
		$this->db->query($query);
	}
}

    'многопоточность'

    Запостил: xXx_totalwar, 07 Февраля 2011

    Комментарии (5) RSS

    Добавить комментарий