work on examples [ci skip]

Author: krakjoe

examples/ClosureFuture.php

@@ -14,7 +14,8 @@ class Future extends Thread {
 
     private function __construct(Closure $closure, array $args = []) {
         $this->closure = $closure;
-        $this->args    = $args;
+        $this->args    = $args;	
+		$this->owner   = Thread::getCurrentThreadId();
     }
 
     public function run() {
@@ -40,7 +41,14 @@ public static function of(Closure $closure, array $args = []) {
         $future->start();
         return $future;
     }
+
+	public function __destruct() {
+		if (Thread::getCurrentThreadId() == $this->owner) {
+			$this->join();
+		}
+	}
 
+	protected $owner;
     protected $closure;
     protected $args;
     protected $result;

examples/Fetch.php

@@ -0,0 +1,36 @@
+<?php
+/*
+	Rules:
+		1. only ever wait FOR something
+		2. only ever wait FOR something
+		3. only ever wait FOR something
+	
+	Read the code ...
+*/
+$thread = new class extends Thread {
+	
+	public function run() {
+		
+		$this->synchronized(function(){
+			$this->awake = true;
+			$this->notify();
+		});
+	}
+};
+
+$thread->start();
+$thread->synchronized(function() use($thread) {
+	while (!$thread->awake) {
+		/*
+			If there was no precondition above and the Thread
+			managed to send notification before we entered this synchronized block
+			we would wait forever!
+
+			We check the precondition in a loop because a Thread can be awoken
+			by signals other than the one you are waiting for.
+		*/
+		$thread->wait();
+	}
+});
+$thread->join();
+?>