boss.py

#!/usr/bin/env python3

import numpy as np

from manager import QueueClient
from task import Task,TaskParameters

import example_robot_data as robex
import pinocchio as pin


class Boss(QueueClient):
    def run(self, qs,vqs,aqs):

        # create some tasks
        for i,[q,v,a] in enumerate(zip(qs,vqs,aqs)):
            self.tasks.put(Task(i,q,v,a))
        # Wait for the results
        results = []
        for _ in range(len(qs)):
            result = self.results.get()
            print(f'got result {result.identifier} of processed in {result.time:.3f}s : ')
            results.append(result)
        print('Got all {tasks} results !')

if __name__ == '__main__':
    import time

    # Allocate data to be proceeded.
    NDATA = 20
    qs  = np.array([ pin.randomConfiguration(TaskParameters.robot.model) for _ in range(NDATA) ])
    vqs = np.random.rand(NDATA,TaskParameters.robot.model.nv)*2-1
    aqs = np.random.rand(NDATA,TaskParameters.robot.model.nv)*2-1

    
    start = time.perf_counter()
    Boss().run(qs,vqs,aqs)
    total = time.perf_counter() - start

    print( f'Completed in {total:.3f} secs')