...

src/kr/co/swh/lecture/python/scene5/scheduler/SchedulerModule.py

@@ -1,35 +1,37 @@
-from apscheduler.jobstores.base import JobLookupError
-from apscheduler.schedulers.background import BackgroundScheduler
-import time
-
-class SchedulerTest:
-    def __init__(self):
-        self.sched = BackgroundScheduler()
-        self.sched.start()
-        self.job_id = ''
-
-    def __del__(self):
-        print("__del__ call")
-        self.shutdown()
-
-    def shutdown(self):
-        self.sched.shutdown()
-
-    def kill_scheduler(self, job_id):
-        try:
-            self.sched.remove_job(job_id)
-        except JobLookupError as err:
-            print("fail to stop Scheduler: {err}".format(err=err))
-            return
-
-    def hello(self, type, job_id):
-        print("%s Scheduler process_id[%s] : %d" % (type, job_id, time.localtime().tm_sec))
-
-    def scheduler(self, type, job_id):
-        print("{type} Scheduler Start".format(type=type))
-        if type == 'interval':
-            self.sched.add_job(self.hello, type, seconds=10, id=job_id, args=(type, job_id))
-        elif type == 'cron':
-            self.sched.add_job(self.hello, type, day_of_week='mon-sun',
-                               hour='0-23', second='*/1',
-                               id=job_id, args=(type, job_id))
+from apscheduler.jobstores.base import JobLookupError
+from apscheduler.schedulers.background import BackgroundScheduler
+import time
+
+class SchedulerTest:
+    def __init__(self):
+        self.sched = BackgroundScheduler()
+        self.job_id = ''
+
+    def __del__(self):
+        print("__del__ call")
+        self.shutdown()
+        
+    def start(self):
+        self.sched.start()
+
+    def shutdown(self):
+        self.sched.shutdown()
+
+    def kill_scheduler(self, job_id):
+        try:
+            self.sched.remove_job(job_id)
+        except JobLookupError as err:
+            print("fail to stop Scheduler: {err}".format(err=err))
+            return
+
+    def hello(self, type, job_id):
+        print("%s Scheduler process_id[%s] : %d" % (type, job_id, time.localtime().tm_sec))
+
+    def scheduler(self, type, job_id):
+        print("{type} Scheduler Start".format(type=type))
+        if type == 'interval':
+            self.sched.add_job(self.hello, type, seconds=10, id=job_id, args=(type, job_id))
+        elif type == 'cron':
+            self.sched.add_job(self.hello, type, day_of_week='mon-sun',
+                               hour='0-23', second='*/1',
+                               id=job_id, args=(type, job_id))

src/kr/co/swh/lecture/python/scene5/scheduler/interval-test.py

@@ -1,19 +1,20 @@
-from SchedulerModule import SchedulerTest
-import time
-
-if __name__ == '__main__':
-    scheduler = SchedulerTest()
-    scheduler.scheduler('interval', "2")
-
-    count = 0
-    while True:
-        '''
-        count 제한할 경우 아래와 같이 사용
-        '''
-        print("Running main process")
-        time.sleep(1)
-        count += 1
-        if count == 15:
-            scheduler.kill_scheduler("2")
-            print("Kill interval Scheduler")
+from SchedulerModule import SchedulerTest
+import time
+
+if __name__ == '__main__':
+    scheduler = SchedulerTest()
+    scheduler.scheduler('interval', "2")
+    scheduler.start()
+    
+    count = 0
+    while True:
+        '''
+        count 제한할 경우 아래와 같이 사용
+        '''
+        print("Running main process")
+        time.sleep(1)
+        count += 1
+        if count == 15:
+            scheduler.kill_scheduler("2")
+            print("Kill interval Scheduler")
             break

src/kr/co/swh/lecture/python/scene5/scheduler/scheduler-1.py

@@ -8,4 +8,5 @@ sched = BackgroundScheduler()
 sched.add_job(tick1, "interval", seconds=2)
 sched.start()
 
-time.sleep(100)
+time.sleep(100)
+

src/kr/co/swh/lecture/python/scene5/scheduler/scheduler-2.py

@@ -0,0 +1,8 @@
+import time
+
+def tick1():
+    print("tick!!!")
+
+while True:
+    tick1()
+    time.sleep(1)