From 68c844df0c086e4895a31f76c2102a22382a6bae Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Jannes=20H=C3=B6ke?= <jhoeke@uni-bremen.de>
Date: Mon, 4 Jan 2016 00:01:00 +0100
Subject: [PATCH] implement starting jobqueue in thread and fix errors

---
 telegram/__init__.py |  3 ++-
 telegram/jobqueue.py | 26 ++++++++++++++++++--------
 2 files changed, 20 insertions(+), 9 deletions(-)

diff --git a/telegram/__init__.py b/telegram/__init__.py
index ea7e978d7..12b2ec193 100644
--- a/telegram/__init__.py
+++ b/telegram/__init__.py
@@ -49,10 +49,11 @@ from .update import Update
 from .bot import Bot
 from .dispatcher import Dispatcher
 from .updater import Updater
+from .jobqueue import JobQueue
 
 __all__ = ['Bot', 'Updater', 'Dispatcher', 'Emoji', 'TelegramError',
            'InputFile', 'ReplyMarkup', 'ForceReply', 'ReplyKeyboardHide',
            'ReplyKeyboardMarkup', 'UserProfilePhotos', 'ChatAction',
            'Location', 'Contact', 'Video', 'Sticker', 'Document', 'File',
            'Audio', 'PhotoSize', 'Chat', 'Update', 'ParseMode', 'Message',
-           'User', 'TelegramObject', 'NullHandler', 'Voice']
+           'User', 'TelegramObject', 'NullHandler', 'Voice', 'JobQueue']
diff --git a/telegram/jobqueue.py b/telegram/jobqueue.py
index a95628df7..ce166ba76 100644
--- a/telegram/jobqueue.py
+++ b/telegram/jobqueue.py
@@ -22,7 +22,7 @@ This module contains the class JobQueue
 
 import logging
 import time
-from threading import Lock
+from threading import Thread, Lock
 
 try:
     from queue import Queue, PriorityQueue
@@ -76,6 +76,8 @@ class JobQueue(object):
         if next_t is None:
             next_t = interval
 
+        next_t += time.time()
+
         self.logger.debug("Putting a {} with t={}".format(
                 job.name, next_t))
         self.queue.put((next_t, job))
@@ -95,8 +97,8 @@ class JobQueue(object):
             if t < now:
                 self.queue.get()
                 self.logger.debug("About time! running")
-                j.run()
-                self.put(j, now + j.interval)
+                j.run(self.bot)
+                self.put(j.run, j.interval)
                 continue
 
             self.logger.debug("Next task isn't due yet. Finished!")
@@ -104,19 +106,27 @@ class JobQueue(object):
 
     def start(self):
         """
-        Thread target of thread 'job_queue'. Runs in background and performs
-        ticks on the job queue.
+        Starts the job_queue thread.
         """
         self.__lock.acquire()
         if not self.running:
             self.running = True
             self.__lock.release()
-            while self.running:
-                self.tick()
-                time.sleep(self.tick_interval)
+            job_queue_thread = Thread(target=self._start,
+                                      name="job_queue")
+            job_queue_thread.start()
         else:
             self.__lock.release()
 
+    def _start(self):
+        """
+        Thread target of thread 'job_queue'. Runs in background and performs
+        ticks on the job queue.
+        """
+        while self.running:
+            self.tick()
+            time.sleep(self.tick_interval)
+
     def stop(self):
         """
         Stops the thread