matlab - 如何在 MatLab Appdesigner 的 parforloop 下运行 NamedPipe 流

Question

我正在 matlab appdesigner 中开发一个软件，它将在 parforloop 下同时运行两个函数。第一个函数有一个NamedPipe 对象，错误是： 使用 uifigure 函数为 app 变量创建的图形不支持功能，也无法加载 .Net 对象。parforloop 下的 NamedPipe 对象有什么问题？如何在 matlab appdesigner 中运行具有并行性的命名管道通信？这是我的代码

 function func1(app)
    %disp('Function 1');
    disp(strcat('Function 1----',datestr(now)));
    pause(2);
    disp(strcat('Function 1----',datestr(now)));
    NET.addAssembly('System.Core');
    MypipeServer  = System.IO.Pipes.NamedPipeServerStream('my_pipe', ...
                    System.IO.Pipes.PipeDirection.InOut, ...
                    System.IO.Pipes.NamedPipeServerStream.MaxAllowedServerInstances,...
                    System.IO.Pipes.PipeTransmissionMode.Byte,...
    System.IO.Pipes.PipeOptions.Asynchronous);
    disp("Waiting for client connection...");
    MypipeServer.WaitForConnection();
    disp("Client Connected");
    disp('Reading data from Client');
    pause(2);

    sr = System.IO.StreamReader(MypipeServer);
    %sw = System.IO.StreamWriter('E:/pipeKo.txt')
    line = sr.ReadLine();
    disp(line);
end
function func2(app)
    %disp('Function 2');
    disp(strcat('Function 2----',datestr(now)));
    pause(2);
    disp(strcat('Function 2----',datestr(now)));


end


 function ClickOnButtonValueChanged(app, event)
    parfor i = 1:2
        if i == 1
          func1(app);
        else
          func2(app);
        end
    end
 end

标签： matlabparallel-processingnamed-pipesmatlab-app-designer

Answer 1

最后，我找到了解决方案。所以我发布答案以供将来帮助。此处应使用parallel.pool.DataQueue 。这是appdesigner的完整代码。对于完整的服务器和客户端代码，您还可以查看这个 github 存储库：命名管道并行通信

methods (Access = private)

    function app= func1(app,data)

        disp(strcat('Function 1----',datestr(now)));
        app.textTextArea.Value=strcat('Function 1----',datestr(now));
        pause(5);
        disp(strcat('Function 1----',datestr(now)));
        NET.addAssembly('System.Core');
        MypipeServer  = System.IO.Pipes.NamedPipeServerStream('my_pipe', ...
                        System.IO.Pipes.PipeDirection.InOut, ...
                        System.IO.Pipes.NamedPipeServerStream.MaxAllowedServerInstances,...
                        System.IO.Pipes.PipeTransmissionMode.Byte,...
        System.IO.Pipes.PipeOptions.Asynchronous);
        disp("Waiting for client connection...");
        app.textTextArea.Value=[app.textTextArea.Value;"Waiting for client connection..."];
        pause(1);
        MypipeServer.WaitForConnection();
        disp("Client Connected");
        app.textTextArea.Value=[app.textTextArea.Value;"Client Connected"];
        disp('Reading data from Client');
        app.textTextArea.Value=[app.textTextArea.Value;"Reading data from Client"];
        pause(1);
        sr = System.IO.StreamReader(MypipeServer);

        line = sr.ReadLine();
        disp(string(line));
        app.textTextArea.Value=[app.textTextArea.Value;string(line)];
        pause(2);
        sw = System.IO.StreamWriter(MypipeServer);
        %sw.AutoFlush = true;
        time = datestr(now);
        disp(time);
        app.textTextArea.Value=[app.textTextArea.Value;time];
        disp("Server: Hello");
        app.textTextArea.Value=[app.textTextArea.Value;"Server: Hello"];
        sw.WriteLine("Hello");
        sw.Flush();
        app.textTextArea.Value=[app.textTextArea.Value;strcat('After Communication----',datestr(now))];
        disp(strcat('After Communication----',datestr(now)));


    end

    function app= func2(app,data)
        %disp('Function 2');

        app.textTextArea.Value = [app.textTextArea.Value;strcat('Function 2----',datestr(now))];
        %pause(1);
        app.textTextArea.Value = [app.textTextArea.Value;strcat('Function 2----',datestr(now))];

    end

end


methods (Access = private)

    % Value changed function: ClickOnButton
    function ClickOnButtonValueChanged(app, event)
        q = parallel.pool.DataQueue;
        r = parallel.pool.DataQueue;

        afterEach(q, @app.func1);
        afterEach(r, @app.func2);
        parfor i = 1:2
            if i == 1
              %func1(app);
              send(q,i);

            else
              %func2(app);
               send(r,i);
            end
        end

    end


end