starred/crono
1
0
Fork 0
mirror of https://github.com/plashchynski/crono.git synced 2026-06-12 09:44:27 +02:00
Code Issues 35 Packages Projects Releases 9 Wiki Activity

Job semaphore

Browse Source
This commit is contained in:
Dzmitry Plashchynski
2015-03-07 17:05:51 +02:00
parent b3920fa2ee
commit b4d15f7909
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/crono/job.rb
+5 -5
View File
@@ -15,7 +15,7 @@ module Crono
self.performer, self.period = performer, period self.performer, self.period = performer, period
self.job_log = StringIO.new self.job_log = StringIO.new
self.job_logger = Logger.new(job_log) self.job_logger = Logger.new(job_log)
@log_semaphore = Mutex.new @semaphore = Mutex.new
end end
def next def next
@@ -42,12 +42,12 @@ module Crono
end end
def save def save
log = model.reload.log || "" @semaphore.synchronize do
@log_semaphore.synchronize do log = model.reload.log || ""
log << job_log.string log << job_log.string
job_log.truncate(job_log.rewind) job_log.truncate(job_log.rewind)
model.update(last_performed_at: last_performed_at, log: log)
end end
model.update(last_performed_at: last_performed_at, log: log)
end end
def load def load
@@ -56,7 +56,7 @@ module Crono
private private
def log(message) def log(message)
@log_semaphore.synchronize do @semaphore.synchronize do
logger.info message logger.info message
job_logger.info message job_logger.info message
end end