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

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

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

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

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

    0.9975

    0.9990

    0.9982

    0.9991

    0.9982

    0.9998

    0.9999

    0.9986

    0.9996

    0.9990

Можно комбинировать 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 функция обновляет указатель на рисунок. Для получения дополнительной информации об указателе объектов смотрите Указатель Объекта Behavior.

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);

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

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

errorFuture = parfeval(@(n) randn(n), 0, 0.5);
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]

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

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

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

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

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