Help with simple example

[sabativi]

Hello,

I am currently using https://github.com/msavin/SteveJobs for handling jobs, but I have one intensive CPU jobs that I want to be able to move to this package.
This job is simple, it just call a meteor method with some params.

I have read the blog article, forum thread and README, but is is unclear to me what to do, is there any way you can make an example so that I can relate to ?

Thanks

[nathanschwarz]

Hello, sure a simple example would be :

import { Meteor } from 'meteor/meteor'
import { Cluster, TaskQueue } from 'meteor/nschwarz:cluster'

function computeSomeHeavyThings(x) {
    const computedValue = 36 + x
    // you can also fetch from any collection here or call a meteor method
    return computedValue
}

const taskMap = {
    'MyHeavyJob': job => computeSomeHeavyThings(job.data.x),
}

function onJobsDone({ value, task }) {
    console.log(value) // 36 + (3 * 6 * 8) => 180
}

const cluster = new Cluster(taskMap)
Meteor.startup(() => {
    if (Cluster.isMaster()) {
        TaskQueue.addEventListener('done', onJobsDone)
        TaskQueue.addTask({ taskType: 'MyHeavyJob', data: { x: 3 * 6 * 8 }})
    }
})

[sabativi]

Thank you so much, I had this feeling that this was simple to set up, but could not grasp it ! Thanks again