import { JobExecutor } from 'job-executor'

const config = require('../config');

var jobExecutor = new JobExecutor(config);

jobExecutor.register("demoJobHandler", async (args) => {

    for (let i = 1; i < 10; i++) {
        await new Promise((resolve, reject) => {
            setTimeout(resolve, 888);
        })
    }

    return { result: 'return value' };
})

//批量任务注册
const batchJob = [
    [
        "demoJobHandler1",
        async (args) => {
            for (let i = 1; i < 10; i++) {
                await new Promise((resolve, reject) => {
                    setTimeout(resolve, 888);
                })
            }

            return { result: 'return value' };
        }
    ],
    [
        "demoJobHandler2",
        async (args) => {
            for (let i = 1; i < 10; i++) {
                await new Promise((resolve, reject) => {
                    setTimeout(resolve, 888);
                })
            }

            return { result: 'return value' };
        }
    ]
]

jobExecutor.registerBatch(batchJob);