Вы можете использовать afterAll для автоматического вызова функций на всех объединенных выходах parfeval вычисления.

Использовать parfeval для вычисления случайных векторов в рабочих. С настройками по умолчанию, parfeval создает parpool автоматически, если он еще не создан.

for idx = 1:10
    f(idx) = parfeval(@rand, 1, 1000, 1);
end

Отображение максимального значения элемента среди всех векторов после их создания. afterAll выполняет дескриптор функции на комбинированном выходе всех фьючерсов, когда они все становятся готовыми.

afterAll(f, @(r) disp(max(r)), 0);

    0.9998

Можно комбинировать afterEach и afterAll для автоматического вызова дополнительных функций по результатам фьючерсов. Оба afterEach и afterAll генерировать будущие переменные, которые могут быть снова использованы в afterEach и afterAll.

Использовать parfeval для вычисления случайных векторов в рабочих. С настройками по умолчанию, parfeval создает parpool автоматически, если он еще не создан.

for idx= 1:10
    f(idx) = parfeval(@rand, 1, 1000, 1);
end

Starting parallel pool (parpool) using the 'local' profile ...
connected to 8 workers.

Вычислите наибольший элемент в каждом из этих векторов, когда они будут готовы. afterEach выполняет дескриптор функции для выходных данных каждого будущего, когда они становятся готовыми, и создает другое будущее для хранения результатов.

maxFuture = afterEach(f, @(r) max(r), 1);

Чтобы вычислить минимальное значение между ними, вызовите afterAll об этом новом будущем. afterAll выполняет функцию для объединенных выходных аргументов всех фьючерсов после их завершения. В этом случае afterAll выполняет функцию min о выходах maxFuture после завершения и создает другое будущее для удержания результата.

minFuture = afterAll(maxFuture, @(r) min(r), 1);

Получить результат можно с помощью fetchOutputs. fetchOutput ждет, пока будущее не завершится, чтобы собрать результаты.

fetchOutputs(minFuture)

ans = 0.9973

Вы можете проверить результат afterEach путем вызова fetchOutputs на его будущей переменной.

fetchOutputs(maxFuture)

ans = 10×1

    0.9996
    0.9989
    0.9994
    0.9973
    1.0000
    1.0000
    0.9989
    0.9994
    0.9998
    0.9999

В этом примере показано, как обновить интерфейс пользователя по мере завершения вычислений. При разгрузке вычислений работникам с помощью parfeval, все пользовательские интерфейсы реагируют, в то время как работники выполняют эти вычисления. В этом примере используется waitbar для создания простого пользовательского интерфейса.

Использовать waitbar чтобы создать маркер перемещения фигуры, h. При использовании afterEach или afterAll, waitbar функция обновляет дескриптор фигуры. Дополнительные сведения об объектах-дескрипторах см. в разделе Поведение объектов-дескрипторов.

h = waitbar(0,'Waiting...');

Использовать parfeval для вычисления действительной части собственных значений случайных матриц. С настройками по умолчанию, parfeval автоматически создает параллельный пул, если он еще не создан.

for idx = 1:100
    f(idx) = parfeval(@(n) real(eig(randn(n))),1,5e2); 
end

Вы можете использовать afterEach для автоматического вызова функций по каждому из результатов parfeval вычисления. Использовать afterEach для вычисления наибольшего значения в каждом из выходных массивов после завершения каждого будущего.

maxFuture = afterEach(f,@max,1);

Вы можете использовать State имущество для получения статуса фьючерса. Создайте логический массив, где State имущество фьючерсов в f является "finished". Использовать mean для расчета доли готового фьючерса. Затем создайте анонимную функцию updateWaitbar. Функция изменяет длину дробной полосы ожидания h к доле готового фьючерса.

updateWaitbar = @(~) waitbar(mean({f.State} == "finished"),h);

Использовать afterEach и updateWaitbar для обновления длины дробной полосы ожидания после каждого будущего в maxFuture завершает. Использовать afterAll и delete закрытие полосы ожидания после завершения всех вычислений.

updateWaitbarFutures = afterEach(f,updateWaitbar,0);
afterAll(updateWaitbarFutures,@(~) delete(h),0);

Использовать afterAll и histogram для отображения гистограммы результатов в maxFuture после завершения всех фьючерсов.

showsHistogramFuture = afterAll(maxFuture,@histogram,0);

Когда вычисления для будущих переменных приводят к ошибке, по умолчанию afterAll не оценивает его функцию. Если вы хотите обработать любые ошибки, например, у вас есть пользовательский интерфейс, который вы хотите обновить, вы можете использовать пару имя-значение PassFuture. Если установлено значение true, будущая переменная передается функции обратного вызова. Вы можете позвонить fetchOutputs на нем обработайте выходные данные и обработайте все возможные ошибки.

Отправка вычислений работникам с помощью parfeval. С настройками по умолчанию, parfeval создает parpool автоматически, если он еще не создан. Если ваш parfeval вычисления приводят к ошибке, будущим ошибкам переменных и их Error свойство отражает его.

errorFuture = parfeval( @(n) randn(n), 0, 0.5);

Starting parallel pool (parpool) using the 'Local' profile ...
connected to 4 workers.

wait(errorFuture);
errorFuture.Error

ans = 
  ParallelException with properties:

     identifier: 'MATLAB:NonIntegerInput'
        message: 'Size inputs must be integers.'
          cause: {}
    remotecause: {[1×1 MException]}
          stack: [1×1 struct]

Если вы используете afterAll в этом будущем функция обратного вызова не оценивается. В приведенном ниже коде msgbox не выполняется из-за будущих ошибок.

afterAll(errorFuture, @() msgbox('Operation completed'), 0);

Для обработки фьючерсов, которые приводят к ошибке, используйте пару имя-значение PassFuture при вызове afterAll. Будущая переменная передается функции обратного вызова вместо ее выходных данных. Звонить fetchOutputs на нем и обрабатывать его результаты. Если будущее приведет к ошибке, fetchOutputs выбрасывает ошибку, которую можно поймать и обработать. Например, следующий код показывает диалоговое окно ошибки.

afterAll(errorFuture, @handleError, 0, 'PassFuture',true);

function handleError (f)
try
    output = fetchOutputs(f);
    % Do something with the output
catch
    errordlg('Operation failed');
end
end