From ac2a584b8d8f62cf4aff97fb99466ddd23ad770e Mon Sep 17 00:00:00 2001
From: ZsBT <kalo@zsombor.net>
Date: Fri, 10 Apr 2015 09:25:23 +0200
Subject: [PATCH] removed checking function existence to support static class
 methods

---
 README.md  |  4 +++-
 Thread.php | 36 +++++++++++++++++++-----------------
 2 files changed, 22 insertions(+), 18 deletions(-)

diff --git a/README.md b/README.md
index 34ab4bf..8e3dc2a 100644
--- a/README.md
+++ b/README.md
@@ -1,4 +1,6 @@
 php-thread
 ==========
 
-Simple implementation of threading in PHP using pnctl
+* Thread.php: Simple implementation of threading in PHP using pnctl
+* ThreadQueue.php: Enqueue tasks to run them in parallel
+
diff --git a/Thread.php b/Thread.php
index 890df98..3e0b492 100644
--- a/Thread.php
+++ b/Thread.php
@@ -34,11 +34,8 @@ class Thread
      * @var array
      */
     private $_errors = array(
-        Thread::FUNCTION_NOT_CALLABLE =>
-            'You must specify a valid function name that can be called '.
-            'from the current scope.',
-        Thread::COULD_NOT_FORK        =>
-            'pcntl_fork() returned a status of -1. No new process was created'
+        Thread::FUNCTION_NOT_CALLABLE => 'You must specify a valid function name that can be called from the current scope.',
+        Thread::COULD_NOT_FORK        => 'pcntl_fork() returned a status of -1. No new process was created'
     );
 
     /**
@@ -55,6 +52,17 @@ class Thread
      * @var integer
      */
     private $_pid;
+    
+    
+    /**
+     * Exits with error
+     *
+     * @return void
+    */
+    
+    private function fatalError($errorCode){
+        throw new Exception( $this->getError($errorCode) );
+    }
 
     /**
      * Checks if threading is supported by the current PHP configuration
@@ -84,6 +92,7 @@ class Thread
      */
     public function __construct( $runnable = null )
     {
+        if(!Thread::isAvailable)throw new Exception("Threads not supported");
         if ( $runnable !== null ) {
             $this->setRunnable($runnable);
         }
@@ -101,10 +110,7 @@ class Thread
         if ( self::isRunnableOk($runnable) ) {
             $this->runnable = $runnable;
         } else {
-            throw new Exception(
-                $this->getError(Thread::FUNCTION_NOT_CALLABLE),
-                Thread::FUNCTION_NOT_CALLABLE
-            );
+            $this->fatalError(Thread::FUNCTION_NOT_CALLABLE);
         }
     }
 
@@ -120,8 +126,7 @@ class Thread
 
     /**
      * Checks if the callback is ok (the function/method
-     * actually exists and is runnable from the current
-     * context)
+     * is runnable from the current context)
      *
      * can be called statically
      *
@@ -131,7 +136,7 @@ class Thread
      */
     public static function isRunnableOk( $runnable )
     {
-        return ( function_exists($runnable) && is_callable($runnable) );
+        return ( is_callable($runnable) );
     }
 
     /**
@@ -166,10 +171,7 @@ class Thread
     {
         $pid = @pcntl_fork();
         if ( $pid == -1 ) {
-            throw new Exception(
-                $this->getError(Thread::COULD_NOT_FORK),
-                Thread::COULD_NOT_FORK
-            );
+                $this->fatalError(Thread::COULD_NOT_FORK);
         }
         if ( $pid ) {
             // parent
@@ -252,4 +254,4 @@ class Thread
         }
     }
 }
-- See more at: http://blog.motane.lu/2009/01/02/multithreading-in-php/#sthash.JevFlLcL.dpuf
+