Skip to content

Instantly share code, notes, and snippets.

@shripadk
Created November 8, 2010 12:49
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save shripadk/667666 to your computer and use it in GitHub Desktop.
Save shripadk/667666 to your computer and use it in GitHub Desktop.
NodeQ = require "#{__dirname}/../lib/NodeQ"
queueAworker = new NodeQ("queueA")
secondsFromNow = (secs) ->
Math.round(Date.now() + (secs * 1000))
minutesFromNow = (minutes) ->
Math.round(Date.now() + (minutes * 60 * 1000))
hoursFromNow = (hours) ->
Math.round(Date.now() + (hours * 60 * 60 * 1000))
daysFromNow = (days) ->
Math.round(Date.now() + (days * 24 * 60 * 60 * 1000))
monthsFromNow = (months) ->
Math.round(Date.now() + (months * 30 * 24 * 60 * 60 * 1000))
yearsFromNow = (years) ->
Math.round(Date.now() + (years * 365 * 24 * 60 * 60 * 1000))
queueAworker.connect()
myJobs =
add: (a, b) ->
console.log "Sum is: "
console.log a + b
sub: (a, b) ->
console.log "Diff is: "
console.log a - b
div: (a, b) ->
console.log "Div is: "
console.log a/b
mul: (a, b) ->
console.log "Mul is: "
console.log a * b
queueAworker.enqueue("div-E", "div", [121, 23.15], secondsFromNow(4))
queueAworker.enqueue("div-F", "div", [14, 27.65], secondsFromNow(4))
queueAworker.enqueue("div-G", "div", [31, 23.45], secondsFromNow(4))
queueAworker.enqueue("div-H", "div", [51, 23.25], secondsFromNow(4))
queueAworker.enqueue("div-I", "div", [11, 23.15], secondsFromNow(4))
queueAworker.start({
assignCallback: myJobs
})
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment