__init__.py 文件源码

def _buildJobs (self):
        """
        Build the jobs.
        """
        self.props['channel'] = Channel.create([None] * self.size)
        rptjob  = 0 if self.size == 1 else randint(0, self.size-1)

        def bjSingle(i):
            job = Job(i, self)
            job.init()
            self.jobs[i] = job
            row = tuple(job.data['out'].values())
            self.props['channel'][i] = row

        utils.parallel(bjSingle, [(i, ) for i in range(self.size)], self.nthread)
        self.log('After job building, active threads: %s' % threading.active_count(), 'debug')

        if self.jobs[0].data['out']:
            self.channel.attach(*self.jobs[0].data['out'].keys())
        self.jobs[rptjob].report()