Multiprocessing cannot deal with bound methods, as they aren't pickleable.
(neObj: ne3.NumExpr, data: dict, N_threads: int=2)
| 676 | # Tests for threading/multiprocessing/concurrent.futures |
| 677 | |
| 678 | def future_worker(neObj: ne3.NumExpr, data: dict, N_threads: int=2): |
| 679 | ''' |
| 680 | Multiprocessing cannot deal with bound methods, as they aren't pickleable. |
| 681 | ''' |
| 682 | ne3.set_nthreads(N_threads) |
| 683 | return neObj(**data) |
| 684 | |
| 685 | |
| 686 | # Case test for subprocesses (via multiprocessing module) |
nothing calls this directly
no outgoing calls
no test coverage detected
searching dependent graphs…