Como: Use grupos de agendamento para influenciar a ordem de execução
O Runtime de simultaneidade, a ordem na qual as tarefas são agendadas é não-determinística. No entanto, você pode usar diretivas de agendamento para influenciar a ordem na qual as tarefas executadas. Este tópico mostra como usar os grupos de agendamento junto com o Concurrency::SchedulingProtocol diretiva Agendador para influenciar a ordem na qual as tarefas executadas.
O exemplo executa um conjunto de tarefas de duas horas, cada um com uma diretiva de agendamento diferente. Ambas as diretivas limitam o número máximo de recursos de processamento para dois. A primeira execução usa o EnhanceScheduleGroupLocality a diretiva, que é o padrão e a segunda execução usa o EnhanceForwardProgress diretiva. Sob o EnhanceScheduleGroupLocality diretiva, o Agendador executa todas as tarefas em um grupo de agendamento até a conclusão de cada tarefa ou produz. Sob o EnhanceForwardProgress o Agendador de diretiva, move para o próximo grupo de agendamento em uma forma de rodízio após a conclusão de apenas uma tarefa ou produz.
Quando cada grupo de agendamento contém tarefas relacionadas, o EnhanceScheduleGroupLocality diretiva geralmente resulta em melhor desempenho, porque a localidade de cache é preservada entre tarefas. O EnhanceForwardProgress diretiva permite que as tarefas tornar o progresso e é útil quando você precisa de agendamento de imparcialidade entre grupos de agendamento.
Exemplo
Este exemplo define o work_yield_agent classe, que é derivada de Concurrency::agent. O work_yield_agent classe realiza uma unidade de trabalho, gera o contexto atual e então executa outra unidade de trabalho. O agente utiliza o Concurrency::wait função cooperativamente produzir o contexto atual para que podem executar a outros contextos.
Este exemplo cria quatro work_yield_agent objetos. Para ilustrar como definir diretivas de Agendador para afeta a ordem na qual os agentes são executados, o exemplo associa os dois primeiros agentes grupo de uma agenda e os outros dois agentes com outro grupo de agendamento. O exemplo usa o Concurrency::CurrentScheduler::CreateScheduleGroup método para criar o Concurrency::ScheduleGroup objetos. O exemplo executa duas vezes, sempre com uma diretiva de agendamento diferente de todos os quatro agentes.
// scheduling-protocol.cpp
// compile with: /EHsc
#include <agents.h>
#include <vector>
#include <algorithm>
#include <iostream>
#include <sstream>
using namespace Concurrency;
using namespace std;
#pragma optimize( "", off )
// Simulates work by performing a long spin loop.
void spin_loop()
{
for (int i = 0; i < 500000000; ++i)
{
}
}
#pragma optimize( "", on )
// Agent that performs some work and then yields the current context.
class work_yield_agent : public agent
{
public:
explicit work_yield_agent(
unsigned int group_number, unsigned int task_number)
: _group_number(group_number)
, _task_number(task_number)
{
}
explicit work_yield_agent(Scheduler& scheduler,
unsigned int group_number, unsigned int task_number)
: agent(scheduler)
, _group_number(group_number)
, _task_number(task_number)
{
}
explicit work_yield_agent(ScheduleGroup& group,
unsigned int group_number, unsigned int task_number)
: agent(group)
, _group_number(group_number)
, _task_number(task_number)
{
}
protected:
// Performs the work of the agent.
void run()
{
wstringstream header, ss;
// Create a string that is prepended to each message.
header << L"group " << _group_number
<< L",task " << _task_number << L": ";
// Perform work.
ss << header.str() << L"first loop..." << endl;
wcout << ss.str();
spin_loop();
// Cooperatively yield the current context.
// The task scheduler will then run all blocked contexts.
ss = wstringstream();
ss << header.str() << L"waiting..." << endl;
wcout << ss.str();
Concurrency::wait(0);
// Perform more work.
ss = wstringstream();
ss << header.str() << L"second loop..." << endl;
wcout << ss.str();
spin_loop();
// Print a final message and then set the agent to the
// finished state.
ss = wstringstream();
ss << header.str() << L"finished..." << endl;
wcout << ss.str();
done();
}
private:
// The group number that the agent belongs to.
unsigned int _group_number;
// A task number that is associated with the agent.
unsigned int _task_number;
};
// Creates and runs several groups of agents. Each group of agents is associated
// with a different schedule group.
void run_agents()
{
// The number of schedule groups to create.
const unsigned int group_count = 2;
// The number of agent to create per schedule group.
const unsigned int tasks_per_group = 2;
// A collection of schedule groups.
vector<ScheduleGroup*> groups;
// A collection of agents.
vector<agent*> agents;
// Create a series of schedule groups.
for (unsigned int group = 0; group < group_count; ++group)
{
groups.push_back(CurrentScheduler::CreateScheduleGroup());
// For each schedule group, create a series of agents.
for (unsigned int task = 0; task < tasks_per_group; ++task)
{
// Add an agent to the collection. Pass the current schedule
// group to the work_yield_agent constructor to schedule the agent
// in this group.
agents.push_back(new work_yield_agent(*groups.back(), group, task));
}
}
// Start each agent.
for_each(agents.begin(), agents.end(), [](agent* a) {
a->start();
});
// Wait for all agents to finsih.
agent::wait_for_all(agents.size(), &agents[0]);
// Free the memory that was allocated for each agent.
for_each(agents.begin(), agents.end(), [](agent* a) {
delete a;
});
// Release each schedule group.
for_each(groups.begin(), groups.end(), [](ScheduleGroup* group) {
group->Release();
});
}
int wmain()
{
// Run the agents two times. Each run uses a scheduler
// policy that limits the maximum number of processing resources to two.
// The first run uses the EnhanceScheduleGroupLocality
// scheduling protocol.
wcout << L"Using EnhanceScheduleGroupLocality..." << endl;
CurrentScheduler::Create(SchedulerPolicy(3,
MinConcurrency, 1,
MaxConcurrency, 2,
SchedulingProtocol, EnhanceScheduleGroupLocality));
run_agents();
CurrentScheduler::Detach();
wcout << endl << endl;
// The second run uses the EnhanceForwardProgress
// scheduling protocol.
wcout << L"Using EnhanceForwardProgress..." << endl;
CurrentScheduler::Create(SchedulerPolicy(3,
MinConcurrency, 1,
MaxConcurrency, 2,
SchedulingProtocol, EnhanceForwardProgress));
run_agents();
CurrentScheduler::Detach();
}
O exemplo produz a seguinte saída.
Using EnhanceScheduleGroupLocality...
group 0,task 0: first loop...
group 0,task 1: first loop...
group 0,task 0: waiting...
group 1,task 0: first loop...
group 0,task 1: waiting...
group 1,task 1: first loop...
group 1,task 0: waiting...
group 0,task 0: second loop...
group 1,task 1: waiting...
group 0,task 1: second loop...
group 0,task 0: finished...
group 1,task 0: second loop...
group 0,task 1: finished...
group 1,task 1: second loop...
group 1,task 0: finished...
group 1,task 1: finished...
Using EnhanceForwardProgress...
group 0,task 0: first loop...
group 1,task 0: first loop...
group 0,task 0: waiting...
group 0,task 1: first loop...
group 1,task 0: waiting...
group 1,task 1: first loop...
group 0,task 1: waiting...
group 0,task 0: second loop...
group 1,task 1: waiting...
group 1,task 0: second loop...
group 0,task 0: finished...
group 0,task 1: second loop...
group 1,task 0: finished...
group 1,task 1: second loop...
group 0,task 1: finished...
group 1,task 1: finished...
Ambas as diretivas produzem a mesma seqüência de eventos. No entanto, a diretiva que usa o EnhanceScheduleGroupLocality inicia os dois agentes que fazem parte do primeiro grupo de agendamento antes de iniciar os agentes que fazem parte do segundo grupo. A diretiva que usa EnhanceForwardProgress inicia um agente do primeiro grupo e inicia o primeiro agente no segundo grupo.
Compilando o código
Copie o código de exemplo e colá-lo em um Visual Studio do projeto, ou colá-lo em um arquivo que é chamado protocol.cpp agendamento e, em seguida, execute o seguinte comando um Visual Studio 2010 janela do Prompt de comando.
cl.exe /EHsc scheduling-protocol.cpp