1. 1
2. 2
3. 3
4. 4
5. 5
6. 6
7. 7
8. 8
9. 9
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);
	}
}