(sim, tau)
| 92 | |
| 93 | def simulate_tau_batch_parallel(sim_batch, q, v, tau_batch, dt): |
| 94 | def rollout_single(sim, tau): |
| 95 | q_ = q.copy() |
| 96 | v_ = v.copy() |
| 97 | sim.rollout(q_, v_, tau, dt) # rollout without GIL |
| 98 | return sim.qnew, sim.vnew |
| 99 | |
| 100 | with concurrent.futures.ThreadPoolExecutor(max_workers=max_workers) as executor: |
| 101 | futures = [ |
nothing calls this directly
no outgoing calls
no test coverage detected