求助，多进程milab如何做？

lovechang1314

王老师好
我想在meteoinfolab中使用Python的multiprocessing，但好像并没有这个标准库，请问您如何在meteinfolab中使用多进程呢？

MeteoInfo

Jython 没有multiprocessing，不过Jython没有GIL全局锁，可以实现真正的多线程。因此可以用多线程来并行。

lovechang1314

收到，谢谢王老师.

lovechang1314

王老师好
能否请您写一个示例代码，不太了解JAVA的多进程，查了很多资料但写出来的要么主进程直接执行没有等待线程运行，要么压根运行不起来。
我修改了milab执行参数，考虑机器性能限制，只分配了1G内存。

另外我尝试将milab执行包装了一层，使用CPython的subprocess来多进程调用，但效率好像比较捉急。。。

MeteoInfo

lovechang1314 发表于 2021-12-12 09:54
王老师好
能否请您写一个示例代码，不太了解JAVA的多进程，查了很多资料但写出来的要么主进程直接执行没有 ...

参考这里：https://github.com/om12nayak/Jython_multithreading_demo

lovechang1314

MeteoInfo 发表于 2021-12-12 12:43
参考这里：https://github.com/om12nayak/Jython_multithreading_demo

我也是找的这个例子...还提了issues...
谢谢您

MeteoInfo

lovechang1314 发表于 2021-12-13 13:52
我也是找的这个例子...还提了issues...
谢谢您

可以参考这段代码：

1. sem = Semaphore(10)    #Maximum thread number
   
2. threads = []
   
3. for r in range(nlon):
   
4.     thread = Thread(target=ffn, args=(sem, r, nlat, fcst_hours, inputs, results))
   
5.     thread.start()
   
6.     threads.append(thread)
   
7. 
   
8. for thread in threads:
   
9.     thread.join()
   
10. 
    
11. results = absolute(results)

sem = Semaphore(10)    #Maximum thread number<br /> threads = []<br /> for r in range(nlon): <br />     thread = Thread(target=ffn, args=(sem, r, nlat, fcst_hours, inputs, results))<br />     thread.start()<br />     threads.append(thread)<br /> <br /> for thread in threads:<br />     thread.join()<br /> <br /> results = absolute(results)