#include<bits/stdc++.h>
#include<conio.h>
using namespace std;
const int N = 1001;
int main()
{
    int space ;//功能部件数
    int inum ;//需要流水处理的指令数目
    int length ;//存储不同时间段各个功能部件内指令值
    char map[N][N];//时空图

    cout << "-------Demo the pipline for float point add.------" << endl;
    cout << "-------Here, we display all the content in the pipeline------" << endl;
    cout << "请输入功能部件数目： " << endl;
    cin >> space;
    cout << "请输入需要流水处理的指令数目" << endl;
    cin >> inum;

    int cnt = 1;
    char flag = 'n';
    length = inum + space -1;

    for(int i=0; i<space; i++)
    {
        int k;
        for(k=0; k<(space-i-1)*3; k++)
            map[i][k] = ' ';
        --k;
        for(int j=0; j<inum; j++)
        {
            map[i][++k+j] = (char)(65+i);
            map[i][++k+j] = j+1+'0';
        }
    }

    while(cnt <=length && flag == 'n')
    {
        //output the cnt-th slice
        for(int i=0; i<space; i++)
        {
            for(int j=0; j<cnt*3; j++)
                cout << map[i][j];
            cout << endl;
        }

        cout << "Input next time slices"<<cnt<< "(y/n)" << endl;  //如果想要看到完整的流水线过程请一直按’n‘
        cnt++;
        cin >> flag;
        cout << endl;
    }

    cout << "The task has been finished" << endl;
    cout << endl;
    cout << "The Though Put of the pipeline is " << inum/(length*1.0) << "Δt" << endl;
    cout << "The Speedup is of the pipeline is " << (inum*space)/(length*1.0) << endl;
    cout << "The Efficiency of the pipeline is " << (inum*space)/(space*length*1.0) << endl;

    getch();
    return 0;
}

#include <bits/stdc++.h>
#include <vector>
#define MAX_CAP 30
using namespace std;
struct Device            //设备定义
{
    int actCap;         //设备容量
    string data;         //内容
};

struct ChannelMannager      //通道处理机
{
    int interrupt;
};

enum state{NONE,INIT,FINISH};

vector <Device> vd(3);        //设备数组

int MaxCap(vector<string> str)        //寻找最大容量
{
    int res=0;
    for (int i=0; i<str.size(); i++)
        if(str[i].size()>=res) res=str[i].size();
    return res;
}

void delay()
{
    int i;
    int r=rand()%500+500;
    for (i=0; i<r; i++);
}

void run(ChannelMannager cm)       //CPU不同的中断算法
{
    while(true)
    {
        if(cm.interrupt==NONE)
        {
            cout<<"The cpu is doing some thing..."<<endl;
            cout<<"The cpu is doing some thing..."<<endl;
            break;
        }

        if(cm.interrupt==INIT)
        {
            cout<<"CPU is interrupted"<<endl;
            cout<<"This is a I/0 Init instruction,The channalManager is init the device..."<<endl;
            break;
        }

        if(cm.interrupt==FINISH)
        {
            cout<<"CPU is interrupted"<<endl;
            cout<<"This is a I/0 Finish instruction,The channalManager is close the device..."<<endl;
            break;
        }
    }
}

void MemoryToDevice(vector<string> memo, int MaxLen, vector<Device> a, ChannelMannager cm)
{
    cm.interrupt=INIT;                                           //通道处理机初始化
    run(cm);
    for (int i=0; i<MaxLen; i++)
    {
        for (int j=0; j<a.size(); j++)
        {
            if(i<memo[j].size() && i<a[j].actCap) a[j].data+=memo[j][i];         //当前位置不大于设备容量且不大于内容长度时，传输给设备
            for (int k=0; k<a.size(); k++)                                                         //打印过程
            {
                cout<<"Device"<<k<<" Content: "<<a[k].data<<endl;
            }
            cout<<endl;
        }

    }

    cm.interrupt=FINISH;                                              //通道处理机状态结束
    run(cm);
}




int main()
{
    cout<<"------------Demo the work flow of channel----------- "<<endl;
    vector<string> memory(3);
    memory[0]="Computer";
    memory[1]="Structure";
    memory[2]="Channel";

    ChannelMannager cm;
    cm.interrupt=NONE;                             //通道处理机状态为空 
    run(cm);
    for (int i=0; i<vd.size(); i++)
    {
        vd[i].data="";        //设备内容初始化为空
        vd[i].actCap=(rand()%10+50);
    }



    int MaxDevCap= MaxCap(memory);
    delay();
    MemoryToDevice(memory,MaxDevCap,vd,cm);

    return 0;
}