Sha256: c97067edefa34b59903ca4bf8fa3a1fab91215fd51794c8dd9f01ce3d3372543
Contents?: true
Size: 407 Bytes
Versions: 17
Compression:
Stored size: 407 Bytes
Contents
module JFlow
class WorkerThread < Thread
def mark_for_shutdown
self["marked_for_shutdown"] = true
end
def marked_for_shutdown?
self["marked_for_shutdown"] == true
end
def currently_working?
self["state"] == :working
end
def currently_polling?
self["state"] == :polling
end
def set_state(state)
self["state"] = state
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems