Made the wakeup() method public

6 files changed, 22 insertions, 19 deletions

diff --git a/apscheduler/schedulers/asyncio.py b/apscheduler/schedulers/asyncio.py
index d830438..b91ee97 100644
--- a/apscheduler/schedulers/asyncio.py
+++ b/apscheduler/schedulers/asyncio.py
@@ -36,7 +36,7 @@ class AsyncIOScheduler(BaseScheduler):
 
     def start(self):
         super(AsyncIOScheduler, self).start()
-        self._wakeup()
+        self.wakeup()
 
     @run_in_event_loop
     def shutdown(self, wait=True):
@@ -50,7 +50,7 @@ class AsyncIOScheduler(BaseScheduler):
     def _start_timer(self, wait_seconds):
         self._stop_timer()
         if wait_seconds is not None:
-            self._timeout = self._eventloop.call_later(wait_seconds, self._wakeup)
+            self._timeout = self._eventloop.call_later(wait_seconds, self.wakeup)
 
     def _stop_timer(self):
         if self._timeout:
@@ -58,7 +58,7 @@ class AsyncIOScheduler(BaseScheduler):
             del self._timeout
 
     @run_in_event_loop
-    def _wakeup(self):
+    def wakeup(self):
         self._stop_timer()
         wait_seconds = self._process_jobs()
         self._start_timer(wait_seconds)
diff --git a/apscheduler/schedulers/base.py b/apscheduler/schedulers/base.py
index bae8e37..088de87 100644
--- a/apscheduler/schedulers/base.py
+++ b/apscheduler/schedulers/base.py
@@ -217,7 +217,7 @@ class BaseScheduler(six.with_metaclass(ABCMeta)):
 
         # Notify the scheduler so it can scan the new job store for jobs
         if self.running:
-            self._wakeup()
+            self.wakeup()
 
     def remove_jobstore(self, alias, shutdown=True):
         """
@@ -362,7 +362,7 @@ class BaseScheduler(six.with_metaclass(ABCMeta)):
         self._dispatch_event(JobEvent(EVENT_JOB_MODIFIED, job_id, jobstore))
 
         # Wake up the scheduler since the job's next run time may have been changed
-        self._wakeup()
+        self.wakeup()
 
     def reschedule_job(self, job_id, jobstore=None, trigger=None, **trigger_args):
         """
@@ -533,6 +533,13 @@ class BaseScheduler(six.with_metaclass(ABCMeta)):
                     else:
                         print(six.u('    No scheduled jobs'), file=out)
 
+    @abstractmethod
+    def wakeup(self):
+        """
+        Notifies the scheduler that there may be jobs due for execution.
+        Triggers :meth:`_process_jobs` to be run in an implementation specific manner.
+        """
+
     #
     # Private API
     #
@@ -687,11 +694,7 @@ class BaseScheduler(six.with_metaclass(ABCMeta)):
 
         # Notify the scheduler about the new job
         if wakeup:
-            self._wakeup()
-
-    @abstractmethod
-    def _wakeup(self):
-        """Triggers :meth:`_process_jobs` to be run in an implementation specific manner."""
+            self.wakeup()
 
     def _create_trigger(self, trigger, trigger_args):
         if isinstance(trigger, BaseTrigger):
diff --git a/apscheduler/schedulers/blocking.py b/apscheduler/schedulers/blocking.py
index 4a1b773..306860f 100644
--- a/apscheduler/schedulers/blocking.py
+++ b/apscheduler/schedulers/blocking.py
@@ -28,5 +28,5 @@ class BlockingScheduler(BaseScheduler):
             self._event.wait(wait_seconds or self.MAX_WAIT_TIME)
             self._event.clear()
 
-    def _wakeup(self):
+    def wakeup(self):
         self._event.set()
diff --git a/apscheduler/schedulers/qt.py b/apscheduler/schedulers/qt.py
index aa6bdf6..dde5afa 100644
--- a/apscheduler/schedulers/qt.py
+++ b/apscheduler/schedulers/qt.py
@@ -21,7 +21,7 @@ class QtScheduler(BaseScheduler):
 
     def start(self):
         super(QtScheduler, self).start()
-        self._wakeup()
+        self.wakeup()
 
     def shutdown(self, wait=True):
         super(QtScheduler, self).shutdown(wait)
@@ -38,7 +38,7 @@ class QtScheduler(BaseScheduler):
                 self._timer.stop()
             del self._timer
 
-    def _wakeup(self):
+    def wakeup(self):
         self._start_timer(0)
 
     def _process_jobs(self):
diff --git a/apscheduler/schedulers/tornado.py b/apscheduler/schedulers/tornado.py
index 95cb297..7809330 100644
--- a/apscheduler/schedulers/tornado.py
+++ b/apscheduler/schedulers/tornado.py
@@ -32,7 +32,7 @@ class TornadoScheduler(BaseScheduler):
 
     def start(self):
         super(TornadoScheduler, self).start()
-        self._wakeup()
+        self.wakeup()
 
     @run_in_ioloop
     def shutdown(self, wait=True):
@@ -46,7 +46,7 @@ class TornadoScheduler(BaseScheduler):
     def _start_timer(self, wait_seconds):
         self._stop_timer()
         if wait_seconds is not None:
-            self._timeout = self._ioloop.add_timeout(timedelta(seconds=wait_seconds), self._wakeup)
+            self._timeout = self._ioloop.add_timeout(timedelta(seconds=wait_seconds), self.wakeup)
 
     def _stop_timer(self):
         if self._timeout:
@@ -54,7 +54,7 @@ class TornadoScheduler(BaseScheduler):
             del self._timeout
 
     @run_in_ioloop
-    def _wakeup(self):
+    def wakeup(self):
         self._stop_timer()
         wait_seconds = self._process_jobs()
         self._start_timer(wait_seconds)
diff --git a/apscheduler/schedulers/twisted.py b/apscheduler/schedulers/twisted.py
index 2829fed..166b613 100644
--- a/apscheduler/schedulers/twisted.py
+++ b/apscheduler/schedulers/twisted.py
@@ -37,7 +37,7 @@ class TwistedScheduler(BaseScheduler):
 
     def start(self):
         super(TwistedScheduler, self).start()
-        self._wakeup()
+        self.wakeup()
 
     @run_in_reactor
     def shutdown(self, wait=True):
@@ -47,7 +47,7 @@ class TwistedScheduler(BaseScheduler):
     def _start_timer(self, wait_seconds):
         self._stop_timer()
         if wait_seconds is not None:
-            self._delayedcall = self._reactor.callLater(wait_seconds, self._wakeup)
+            self._delayedcall = self._reactor.callLater(wait_seconds, self.wakeup)
 
     def _stop_timer(self):
         if self._delayedcall and self._delayedcall.active():
@@ -55,7 +55,7 @@ class TwistedScheduler(BaseScheduler):
             del self._delayedcall
 
     @run_in_reactor
-    def _wakeup(self):
+    def wakeup(self):
         self._stop_timer()
         wait_seconds = self._process_jobs()
         self._start_timer(wait_seconds)