concurrency_simulator_uva210.cpp

#include <cstdio>
#include <queue>
#include <cstring>
#include <cstdlib>
#include <cctype>
using namespace std;

const int maxn = 1000;

// 等待队列(双端队列)
deque<int> readyQ;
// 阻止队列(普通队列)
queue<int> blockQ;

// 共有n条语句
int n;

// 每个程序运行限制时间
int quantum;
// 五个语句分别需要的单位时间
int c[5];

// 变量
int var[26];

// ip[pid]是程序pid的当前行号
int ip[maxn];

// 是否锁定
bool locked;
// 所有程序都存在prog数组，更类似真实的情况，代码也更短
char prog[maxn][10];

void run(int pid)
{
  int q = quantum;
  while (q > 0)
  {
    char *p = prog[ip[pid]];
    switch (p[2])
    {
    case '=':
      var[p[0] - 'a'] = isdigit(p[5]) ? (p[4] - '0') * 10 + p[5] - '0' : p[4] - '0';
      q -= c[0];
      break;
    case 'i': // print
      printf("%d: %d\n", pid + 1, var[p[6] - 'a']);
      q -= c[1];
      break;
    case 'c': // lock
      if (locked)
      {
        blockQ.push(pid);
        return;
      }
      locked = true;
      q -= c[2];
      break;
    case 'l': // unlock
      locked = false;
      if (!blockQ.empty())
      {
        int pid2 = blockQ.front();
        blockQ.pop();
        readyQ.push_front(pid2);
      }
      q -= c[3];
      break;
    case 'd': // end
      return;
    }
    ip[pid]++;
  }
  readyQ.push_back(pid);
}

int main()
{
  // 共有T个语句
  int T;
  scanf("%d", &T);
  while (T--)
  {
    scanf("%d %d %d %d %d %d %d\n", &n, &c[0], &c[1], &c[2], &c[3], &c[4], &quantum);
    memset(var, 0, sizeof(var));

    int line = 0;
    for (int i = 0; i < n; i++)
    {
      // stdin本质是一个文件句柄
      // fgets到达行末停止，到达eof返回null
      fgets(prog[line++], maxn, stdin);
      ip[i] = line - 1;
      while (prog[line - 1][2] != 'd') // 如果没遇到end
        fgets(prog[line++], maxn, stdin);
      readyQ.push_back(i);
    }

    locked = false;
    while (!readyQ.empty())
    {
      int pid = readyQ.front();
      readyQ.pop_front();
      run(pid);
    }
    if (T)
      printf("\n");
  }
  return 0;
}