你可以用另一种方式来解决这个问题,并使用文件系统作为在 MATLAB 和 Python 之间传递消息的一种方式。
在您的 MATLAB 代码中,每次更改变量时,检查它是否超过某个阈值。如果是,请在预定位置创建一个新文件。将此视为触发事件。
现在在你的 python 代码中,使用一些可用的方法来监听文件系统中的变化,并通过指示一些变量来中断循环来响应。
编辑
这是提出的解决方案的框架:
matlab_script.m
%# directory that Python code is watching for modifications
dirPath = 'some_directory';
x = 0;
for i=1:1000
%# some lengthy operation
pause(0.5)
x = x + 1;
%# check if variable exceeds threshold
if x > 10
%# save the workspace to MAT-file inside the directory watched.
%# this shall trigger the notification in Python
save( fullfile(dirPath,'out.mat') )
break
end
end
python_code.py
import os, sys, time
import win32file, win32event, win32con
# stub your functions in my case
def connectToMatlab():
pass
def getValueFromMatlab():
return 99
# path to predetermined directory to watch
dirPath = "some_directory"
dirPath = os.path.abspath(dirPath)
# start/connect to a MATLAB session, running the script above
connectToMatlab()
# set up folder watching (notify on file addition/deletion/renaming)
print "Started watching '%s' at %s" % (dirPath, time.asctime())
change_handle = win32file.FindFirstChangeNotification(
dirPath, 0, win32con.FILE_NOTIFY_CHANGE_FILE_NAME)
# time-out in 10 sec (win32event.INFINITE to wait indefinitely)
timeout = 10000
try:
# block/wait for notification
result = win32event.WaitForSingleObject(change_handle, timeout)
# returned because of a change notification
if result == win32con.WAIT_OBJECT_0:
# retrieve final result from MATLAB
print "MALTAB variable has exceeded threshold at %s" % time.asctime()
val = getValueFromMatlab()
# timed out
elif result == win32con.WAIT_TIMEOUT:
print "timed-out after %s msec at %s" % (timeout,time.asctime())
val = None # maybe to indicate failure
finally:
# cleanup properly
win32file.FindCloseChangeNotification(change_handle)
# work with val
print val
该WaitForSingleObject
函数首先检查指定对象的状态。如果它是无信号的,则调用线程进入有效的等待状态,并在等待对象发出信号(或超时间隔过去)时消耗非常少的处理器时间。
您会看到,当线程引用处于非信号状态的对象时,会立即进行上下文切换,即从处理器中取出它并进入等待/睡眠模式。稍后当对象发出信号时,线程被放回可运行队列并准备好执行。
在这种等待中,虽然在上下文切换中存在一些开销,但在等待状态下不会浪费 CPU 周期。
将此与“轮询并等待”方法进行比较,其中线程在某种循环中等待并检查感兴趣对象的状态。这被称为自旋或忙等待,这可以证明是对 CPU 周期的浪费。
现在感谢 pywin32 模块,我们可以直接使用这些WaitFor...
功能。该实现应该是MSDN 中给出的标准示例的直接移植。
或者,您可以使用 PyQt 库及其QFileSystemWatcher类,而不是直接使用 Win32 API。