如何在非阻塞线程中使用rpy2从Python调用R代码？

这个坑我之前踩过！你遇到的核心问题是rpy2依赖的R C API本身不是线程安全的，rpy2为了避免冲突，默认会在主线程初始化R环境时绑定一个全局锁——这就导致子线程里调用R代码时，会被这个锁死死卡住，直到主线程释放它，但你的主线程一直在等子线程完成，自然就陷入了阻塞，只能打印一次"R running"。

你尝试把rpy2.objects的导入移到线程函数里是个正确的方向，但还差关键一步：在子线程内部手动初始化R的接口环境。如果主线程之前已经碰过rpy2的核心模块，R环境已经被初始化并绑定到主线程了，子线程单纯导入模块还是会复用这个绑定好的环境，锁的问题依然存在。

正确的实现代码 #

import threading
import time

def run_r_task():
    # 子线程内部单独初始化R接口
    import rpy2.rinterface as rinterface
    rinterface.initr()  # 初始化当前线程的R环境
    
    # 现在再导入robjects并执行R代码
    import rpy2.robjects as robjects
    robjects.r('Sys.sleep(10)')
    
    # 可选：执行完后关闭当前线程的R环境
    rinterface.endr()

# 启动子线程
r_thread = threading.Thread(target=run_r_task)
r_thread.start()

# 主线程继续执行自己的逻辑
for _ in range(5):
    print("R running")
    time.sleep(2)

r_thread.join()

为什么这样能解决问题？ #

• rinterface.initr()会在当前子线程中单独初始化一个R运行环境，完全独立于主线程的环境，不会共享锁。
• 不在主线程提前导入rpy2.robjects或rpy2.rinterface，避免主线程提前绑定R环境的锁。

另一种可选方案：手动管理线程锁 #

如果你的场景必须在主线程初始化rpy2，可以启用rpy2的线程支持，然后手动控制锁的获取和释放：

import threading
import time
import rpy2.rinterface as rinterface

# 主线程初始化时启用线程支持
rinterface.initr()
rinterface.thread_init()

def run_r_task():
    import rpy2.robjects as robjects
    # 手动获取锁执行R代码，执行完自动释放
    with rinterface.get_lock():
        robjects.r('Sys.sleep(10)')

r_thread = threading.Thread(target=run_r_task)
r_thread.start()

for _ in range(5):
    print("R running")
    time.sleep(2)

r_thread.join()

这种方案的核心是rinterface.thread_init()开启了rpy2的线程安全模式，配合with rinterface.get_lock()确保同一时间只有一个线程在执行R代码，但主线程的其他逻辑（比如打印）不会被阻塞，因为锁只在执行R代码时持有。

内容的提问来源于stack exchange，提问作者Dennis Soemers