Call the function ``predicate`` on ``nProcs`` processors for ``nTemps`` different temperatures.
(mech, predicate, nProcs, nTemps)
| 54 | |
| 55 | |
| 56 | def parallel(mech, predicate, nProcs, nTemps): |
| 57 | """ |
| 58 | Call the function ``predicate`` on ``nProcs`` processors for ``nTemps`` |
| 59 | different temperatures. |
| 60 | """ |
| 61 | P = ct.one_atm |
| 62 | X = 'CH4:1.0, O2:1.0, N2:3.76' |
| 63 | with multiprocessing.Pool( |
| 64 | processes=nProcs, initializer=init_process, initargs=(mech,) |
| 65 | ) as pool: |
| 66 | y = pool.map(predicate, |
| 67 | zip(itertools.repeat(mech), |
| 68 | np.linspace(300, 900, nTemps), |
| 69 | itertools.repeat(P), |
| 70 | itertools.repeat(X))) |
| 71 | return y |
| 72 | |
| 73 | |
| 74 | def serial(mech, predicate, nTemps): |
no outgoing calls
no test coverage detected