processdlg.cpp

一个比较详细的操作系统进程同步模拟的例子

// PROCESSDlg.cpp : implementation file
//

#include "stdafx.h"
#include "PROCESS.h"
#include "PROCESSDlg.h"
#include "WakeUpDlg.h"
#include "CreateWayDlg.h"
#include "CreateDlg.h"
#include "MemoryDlg.h"
#include "fstream.h"

#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif

/////////////////////////////////////////////////////////////////////////////
// CAboutDlg dialog used for App About

class CAboutDlg : public CDialog
{
public:
	CAboutDlg();

// Dialog Data
	//{{AFX_DATA(CAboutDlg)
	enum { IDD = IDD_ABOUTBOX };
	//}}AFX_DATA

	// ClassWizard generated virtual function overrides
	//{{AFX_VIRTUAL(CAboutDlg)
	protected:
	virtual void DoDataExchange(CDataExchange* pDX);    // DDX/DDV support
	//}}AFX_VIRTUAL

// Implementation
protected:
	//{{AFX_MSG(CAboutDlg)
	//}}AFX_MSG
	DECLARE_MESSAGE_MAP()
};

CAboutDlg::CAboutDlg() : CDialog(CAboutDlg::IDD)
{
	//{{AFX_DATA_INIT(CAboutDlg)
	//}}AFX_DATA_INIT
}

void CAboutDlg::DoDataExchange(CDataExchange* pDX)
{
	CDialog::DoDataExchange(pDX);
	//{{AFX_DATA_MAP(CAboutDlg)
	//}}AFX_DATA_MAP
}

BEGIN_MESSAGE_MAP(CAboutDlg, CDialog)
	//{{AFX_MSG_MAP(CAboutDlg)
		// No message handlers
	//}}AFX_MSG_MAP
END_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////
// CPROCESSDlg dialog

CPROCESSDlg::CPROCESSDlg(CWnd* pParent /*=NULL*/)
	: CDialog(CPROCESSDlg::IDD, pParent)
{
	//{{AFX_DATA_INIT(CPROCESSDlg)
	//}}AFX_DATA_INIT
	// Note that LoadIcon does not require a subsequent DestroyIcon in Win32
	m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);

	RealTime_ReadyList = new struct PCB;
	RealTime_ReadyList->next = NULL;
	Ordiary_BlockList = new struct PCB;
	Ordiary_BlockList->next = NULL;
	Ordiary_ReadyList = new struct PCB;
	Ordiary_ReadyList->next = NULL;
	m_PCBBlocked = new struct PCB;
	m_PCBBlocked->next = NULL;
	m_isClick = FALSE;
	m_isRunning = false;
}

void CPROCESSDlg::DoDataExchange(CDataExchange* pDX)
{
	CDialog::DoDataExchange(pDX);
	//{{AFX_DATA_MAP(CPROCESSDlg)
	DDX_Control(pDX, IDC_PROGRESS_PROCESS, m_ProcessRun);
	DDX_Control(pDX, IDC_PROGRESS_TIMEPIECE, m_TimePieceRun);
	DDX_Control(pDX, IDC_LIST4, m_ListCtrl_Running);
	DDX_Control(pDX, IDC_LIST3, m_ListCtrl_Blocked);
	DDX_Control(pDX, IDC_LIST2, m_ListCtrl_Ordinary);
	DDX_Control(pDX, IDC_LIST1, m_ListCtrl_Process);
	//}}AFX_DATA_MAP
}

BEGIN_MESSAGE_MAP(CPROCESSDlg, CDialog)
	//{{AFX_MSG_MAP(CPROCESSDlg)
	ON_WM_SYSCOMMAND()
	ON_WM_PAINT()
	ON_WM_QUERYDRAGICON()
	ON_BN_CLICKED(IDC_BUTTON_CREATE, OnCreate)
	ON_BN_CLICKED(IDC_BUTTON_CANCELL, OnCancell)
	ON_BN_CLICKED(IDC_BUTTON_BLOCK, OnBlock)
	ON_BN_CLICKED(IDC_BUTTON_WAKEUP, OnWakeup)
	ON_WM_TIMER()
	ON_WM_ERASEBKGND()
	ON_WM_CTLCOLOR()
	ON_NOTIFY(NM_DBLCLK, IDC_LIST4, OnDblclkList4)
	ON_NOTIFY(NM_DBLCLK, IDC_LIST3, OnDblclkList3)
	ON_NOTIFY(NM_DBLCLK, IDC_LIST2, OnDblclkList2)
	ON_NOTIFY(NM_DBLCLK, IDC_LIST1, OnDblclkList1)
	ON_BN_CLICKED(IDC_BUTTON_MEMORY, OnMemory)
	//}}AFX_MSG_MAP
END_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////
// CPROCESSDlg message handlers

BOOL CPROCESSDlg::OnInitDialog()
{
	CDialog::OnInitDialog();

	// Add "About..." menu item to system menu.

	// IDM_ABOUTBOX must be in the system command range.
	ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);
	ASSERT(IDM_ABOUTBOX < 0xF000);

	CMenu* pSysMenu = GetSystemMenu(FALSE);
	if (pSysMenu != NULL)
	{
		CString strAboutMenu;
		strAboutMenu.LoadString(IDS_ABOUTBOX);
		if (!strAboutMenu.IsEmpty())
		{
			pSysMenu->AppendMenu(MF_SEPARATOR);
			pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);
		}
	}

	// Set the icon for this dialog.  The framework does this automatically
	//  when the application's main window is not a dialog
	SetIcon(m_hIcon, TRUE);			// Set big icon
	SetIcon(m_hIcon, FALSE);		// Set small icon
	
	// TODO: Add extra initialization here
    

    InitialListCtrl();//初始化CListCtrl

	m_TimePieceRun.SetRange(0,200);//初始化时间片进度条
    m_TimePieceRun.SetStep(20);
    m_TimePieceRun.SetPos(0);

	m_ProcessRun.SetRange(0,200);//初始化进程执行进度进度条
    //m_ProcessRun.SetStep(20);
    m_ProcessRun.SetPos(0);

	return TRUE;  // return TRUE  unless you set the focus to a control
}


void CPROCESSDlg::OnSysCommand(UINT nID, LPARAM lParam)
{
	if ((nID & 0xFFF0) == IDM_ABOUTBOX)
	{
		CAboutDlg dlgAbout;
		dlgAbout.DoModal();
	}
	else
	{
		CDialog::OnSysCommand(nID, lParam);
	}
}

// If you add a minimize button to your dialog, you will need the code below
//  to draw the icon.  For MFC applications using the document/view model,
//  this is automatically done for you by the framework.

void CPROCESSDlg::OnPaint() 
{
	if (IsIconic())
	{
		CPaintDC dc(this); // device context for painting

		SendMessage(WM_ICONERASEBKGND, (WPARAM) dc.GetSafeHdc(), 0);

		// Center icon in client rectangle
		int cxIcon = GetSystemMetrics(SM_CXICON);
		int cyIcon = GetSystemMetrics(SM_CYICON);
		CRect rect;
		GetClientRect(&rect);
		int x = (rect.Width() - cxIcon + 1) / 2;
		int y = (rect.Height() - cyIcon + 1) / 2;

		// Draw the icon
		dc.DrawIcon(x, y, m_hIcon);
	}
	else
	{
		CDialog::OnPaint();
	}
}

// The system calls this to obtain the cursor to display while the user drags
//  the minimized window.
HCURSOR CPROCESSDlg::OnQueryDragIcon()
{
	return (HCURSOR) m_hIcon;
}
//创建进程
void CPROCESSDlg::OnCreate() 
{
	// TODO: Add your control notification handler code here
	CCreateWayDlg dlg;
	dlg.DoModal();

	//选择创建进程的方式
	if(dlg.radio1 == true)//手工创建进程
	{
		CCreateDlg dlg;
		dlg.DoModal();

		struct PCB * m_PCB = new struct PCB;
		m_PCB->processID = dlg.ProcessID;
		m_PCB->processName = dlg.ProcessName;
		m_PCB->kind = dlg.Kind;
		m_PCB->needTime = dlg.NeedTime;
		m_PCB->priority = dlg.Priority;
		m_PCB->state = dlg.state;
        m_PCB->occupySize = rand()%5 + 3;
		m_PCB->next = NULL;
		if(!LookForPartition(m_PCB))//为创建的进程寻找分区
		{
			CString s = "进程";
			CString str;
			str.Format("%d",m_PCB->processID);
			s += str;
			s += "没有合适的分区，创建失败!";
			AfxMessageBox(s);		
			return;
		}  

		if(m_PCB->priority > 0)
			this->RealTime_Insert(m_PCB);//将创建的实时进程插入到实时就绪队列中
		else                   
			this->Ordinary_Insert(m_PCB);//将创建的分时进程和批处理进程插入到就绪队列中
        //如果创建的是实时进程,且此进程优先级比正在运行的进程优先级高，
		//则先将正在运行的进程插入到就绪队列中，再
		if(m_isRunning == true)
		{
	    	if(m_PCB->priority > m_PCBRunning->priority)
			{
				m_TimePieceRun.SetPos(0);
		    	m_ProcessRun.SetPos(0);
			    m_PCBRunning->needTime = this->remainTime;
				m_PCBRunning->state = "READY";
				if(m_PCBRunning->priority > 0)
					 RealTime_Insert(m_PCBRunning);
				else
					 Ordinary_Insert(m_PCBRunning);
				ExecutingProcess();
			}
		}
		else
		{
				ExecutingProcess();//如果现在没有正在执行的进程，则重新进行进程调度
		}

	}
	else
	if(dlg.radio2 == true)//从文件中读取文件信息
	{
	    Read();
		if(m_isRunning == false)//如果现在没有正在执行的进程，则执行刚读取的这些进程
	        ExecutingProcess();
	}
	else
		AfxMessageBox("Please choose a way of creating a process");
}
//撤销进程
void CPROCESSDlg::OnCancell() 
{
	// TODO: Add your control notification handler code here
	AfxMessageBox("提示:双击某进程，即可将其删除");
}
//阻塞进程
void CPROCESSDlg::OnBlock() 
{
	// TODO: Add your control notification handler code here
	if(!strcmp(m_ListCtrl_Running.GetItemText(0,0),""))
	{
		AfxMessageBox("There is not running process!");
		return;
	}
	m_PCBBlocked = m_PCBRunning;
	m_PCBBlocked->state = "BLOCKED";
	m_PCBBlocked->needTime = remainTime;
    int n = rand()%13;                          //生成随机数
	if(n <= 3)                                  //随机选择阻塞原因
	{
       m_PCBBlocked->blockedReason = "Printer";//阻塞原因：打印机忙
	}

    if((n > 3)&&(n <= 6))       
	{
        m_PCBBlocked->blockedReason = "New operarion";//阻塞原因：启动新操作
	}
    if(n > 6 )
	{
        m_PCBBlocked->blockedReason = "New data";//阻塞原因：新数据尚未到达
	}
    Bolcked_Insert(m_PCBBlocked);
	ShowBlocked();
    if(Ordiary_ReadyList->next != NULL)
	    ExecutingProcess();
	else
	{
		KillTimer(1);
        m_ListCtrl_Running.DeleteAllItems();
		m_TimePieceRun.SetPos(0);
		m_ProcessRun.SetPos(0);
		AfxMessageBox("就需队列已空，暂无可执行的程序!");
	}

}
//唤醒进程
void CPROCESSDlg::OnWakeup() 
{
	// TODO: Add your control notification handler code here
	CWakeUpDlg dlg;
	dlg.DoModal();

	if(dlg.radio1 == true)
	{
       this->GetBlocked_Printer();
	}
	if(dlg.radio2 == true)
	{
       this->GetBlocked_NewData();
	}
	if(dlg.radio3 == true)
	{
       this->GetBlocked_NewOperation();
	}
}
//从文件中读取新建进程的信息
void CPROCESSDlg::Read()
{
    ifstream fin("newProcess.txt");           //打开文件,读取新建进程信息
	char temp[50];                            //字符缓冲区
	int  n = 0;                               //新创建的进程个数

	while(!fin.eof())
	{
		struct PCB * m_PCB = new struct PCB;