假设一个 Python 程序,内部有一个子线程。那么 C++调用该程序时,子线程不会自动运行。只有 C++在调用 Python 程序时,该子线程才会随之运行一小段时间。
示例 Python 程序 test_python_thread.py
如下,调用的 c++代码test_python_thread.cpp
附在后面。编译后直接运行./test_python_thread
无输出,输入xxx
后输出十个数字后停止。但按道理,python 代码应该会每秒钟输出一个数字。
我想知道怎么才能让 Python 里面的子线程能够不间断运行(每秒钟输出 1 个数字)?
#!/usr/bin/env python
# encoding: utf-8
import thread, time
class PyTest:
def __init__(self):
def local_python_thread(s):
while True:
print "local_python_thread", s
s += 1
time.sleep(1)
thread.start_new_thread(local_python_thread, (0, ))
def xxx(self):
s = 0
while s < 10:
print "cpp_thread", s
s += 1
time.sleep(1)
示例 C++程序 (test_python_thread.cpp
)
#include <python2.7/Python.h>
#include <boost/python.hpp>
#include <boost/filesystem.hpp>
#include <iostream>
#include <thread>
namespace bp = boost::python;
class CppTest
{
private:
bp::object python_module;
bp::object python_class;
bp::object python_object;
bp::object python_xxx;
public:
CppTest()
{
Py_Initialize(); // 初始化
PyRun_SimpleString("import sys");
boost::filesystem::path path = "./test_python_thread.py";
std::string chdir_cmd = std::string("sys.path.append(\"") + path.parent_path().c_str() + "\")";
PyRun_SimpleString("sys.path.append('./')");
PyRun_SimpleString(chdir_cmd.c_str());
python_module = bp::import(path.stem().c_str());
python_class = python_module.attr("PyTest");
python_object = python_class();
python_xxx = python_object.attr("xxx");
}
virtual void xxx()
{
python_xxx();
}
};
int main()
{
CppTest test{};
std::string cmd;
while (true) {
std::getline(std::cin, cmd);
if (cmd == "xxx") {
test.xxx();
}
}
return 0;
}
编译 cpp(需要 boost 库):
g++ -std=c++0x -o test_python_thread test_python_thread.cpp -lboost_system -l boost_filesystem -l python2.7 -g -I /usr/include/python2.7/ -l boost_python
1
hl 2017-08-17 18:27:44 +08:00
每太看懂啥意思,不知道是不是因为没有 join 线程的问题导致的.
|
2
albertofwb 2017-08-17 18:38:44 +08:00 via Android
主进程退出之后,其所创建的所有子线程也会退出。python 创建子线程的时候,有一个属性里设置好之后,可以防止这个。好像是 SetDaemon(True) 这个属性。
|
3
dbow 2017-08-17 18:49:12 +08:00
主线程退出 ,daemon thread 也会退出 , 换成下面的方式试试。
t = threading.Thread(target=local_python_thread, args=(0, )) t.start() -> daemon A boolean value indicating whether this thread is a daemon thread (True) or not (False). This must be set before start() is called, otherwise RuntimeError is raised. Its initial value is inherited from the creating thread; the main thread is not a daemon thread and therefore all threads created in the main thread default to daemon = False. |
4
takeoffyoung 2017-08-17 18:57:52 +08:00
thread 已经是 deprecated 了
推荐的做法是,创建一个继承自 threading.Thread 的类的实例 obj.(需要实现 run()函数) 然后 obj.setDaemon(True); obj.start(); while threading.active() > 0: pass 保证主进程不退出,后台线程得以正确运行 |
5
wangxn 2017-08-17 19:39:09 +08:00 via Android
那个创建的线程直接被回收了吧……连引用都没。
|
6
zhiqiang OP @albertofwb @dbow 主进程没有退出,一直在 getline 等待用户输入。
|
7
zhiqiang OP 那个线程一直还在,只是没有运行。
每次输入 xxx 后会该线程会运行输出 10 个数。 |
8
zhouheyang0919 2017-08-17 20:46:04 +08:00 1
|
9
zhouheyang0919 2017-08-17 20:48:06 +08:00
|
10
ysc3839 2017-08-17 22:12:46 +08:00
@zhouheyang0919
这里有个说明: https://docs.python.org/3/c-api/init.html#releasing-the-gil-from-extension-code 大概是说,你的程序在执行耗时操作,同时不调用 Python 的话这样写代码: Py_BEGIN_ALLOW_THREADS ... Do some blocking I/O operation ... Py_END_ALLOW_THREADS 可以让 Python 的线程并行运行。 |
11
ysc3839 2017-08-17 22:14:54 +08:00
@ysc3839 https://stackoverflow.com/a/25819019 这里有个代码示例
|
12
zhiqiang OP 谢谢 @ysc3839 @zhouheyang0919 点到位了。我面临的情况比示例要复杂,C++和 Python 里都有多线程,而且互相调用。我先去尝试一下,有问题再请教。
|