Add helper methods to track working jobs

lib/Resque.php

@@ -189,6 +189,17 @@ public static function size($queue)
 		return self::redis()->llen('queue:' . $queue);
 	}
 
+	/**
+	 * Return the size (number of working jobs) of the specified queue.
+	 *
+	 * @param string $queue name of the queue to be checked for working jobs
+	 *
+	 * @return int The size of the working queue.
+	 */
+	public static function sizeWorking($queue) {
+		return Resque::redis()->llen('working:' . $queue);
+	}
+
 	/**
 	 * Create a new job and save it to the specified queue.
 	 *

lib/Resque/Job.php

@@ -193,6 +193,7 @@ public function perform()
 	{
 		try {
 			Resque_Event::trigger('beforePerform', $this);
+			Resque::redis()->lpush('working:' . $this->queue, $this->payload['id']);
 
 			$instance = $this->getInstance();
 			if(method_exists($instance, 'setUp')) {
@@ -205,6 +206,7 @@ public function perform()
 				$instance->tearDown();
 			}
 
+			Resque::redis()->lrem('working:' . $this->queue, 0, $this->payload['id']);
 			Resque_Event::trigger('afterPerform', $this);
 		}
 		// beforePerform/setUp have said don't perform this job. Return.
@@ -220,8 +222,8 @@ public function perform()
 	 *
 	 * @param $exception
 	 */
-	public function fail($exception)
-	{
+	public function fail($exception) {
+		Resque::redis()->lrem('working:' . $this->queue, 0, $this->payload['id']);
 		Resque_Event::trigger('onFailure', array(
 			'exception' => $exception,
 			'job' => $this,
@@ -250,7 +252,8 @@ public function recreate()
 			$monitor = true;
 			$status->update(Resque_Job_Status::STATUS_WAITING);
 		}
-
+
+		Resque::redis()->lrem('working:' . $this->queue, 0, $this->payload['id']);
 		Resque_Event::trigger('onRecreate', array(
 			'job' => $this,
 		));