#include <windows.h>//必要的头文件,使用Windows API函数

#include <iostream.h>

int index = 0;

int tickets = 100;//票数

HANDLE hMutex; //使用全局的互斥对象来保证对同一资源的互斥访问与操作这里是tickets

//线程处理函数原型,形式可从MSDN中拷贝

//线程1 的入口函数

DWORD WINAPI Fun1Proc(

LPVOID lpParameter   // thread data

);

DWORD WINAPI Fun2Proc(

LPVOID lpParameter   // thread data

);

void main(){

HANDLE hThread1;

DWORD thread1ID;

//创建线程1

hThread1 = CreateThread(NULL, 0, Fun1Proc, NULL, 0, &thread1ID);

HANDLE hThread2;

DWORD thread2ID;

//创建线程2

hThread2 = CreateThread(NULL, 0, Fun2Proc, NULL, 0, &thread2ID);

CloseHandle(hThread1); //关闭线程的句柄，为什么要关闭？它将线程的使用计数减1

CloseHandle(hThread2);//这样当线程结束时，线程内核对象被释放，

//否则只有当进程结束，才释放线程的内核对象hThread1与hThread2

//创建一个互斥对象,如果成功返回互斥对象的句柄,否则返回NULL

hMutex = CreateMutex(NULL, FALSE, "tickets");

if (hMutex)

{

if(ERROR_ALREADY_EXISTS == GetLastError())

{

cout << "only one instance can run!" << endl;

return;

}

}

//      while(index++ < 100)

//      {

//                cout << "main Thread is running!" << endl;

//      }

Sleep(4000);//主线程睡眠4秒钟,给其它线程运行的时间,因为一旦主线程退出则进行退出,其它线程也将退出

}

DWORD WINAPI Fun1Proc(

LPVOID lpParameter   // thread data

){

//      while(index++ < 100)

//                cout << "Thread1 is running!" + index << endl;

while(TRUE){

WaitForSingleObject(hMutex, INFINITE);//如果全局互斥对象是有信号状态,则获得该对象,

//直到调用ReleaseMutex之前,互斥对象是无信号状态,其它线程不能对互斥对象进行访问

if(tickets > 0)

{

Sleep(1);

cout << "Thread1 sell tickets : " << tickets-- << endl;

}

else

break;

ReleaseMutex(hMutex);//将互斥对象设置为有信号状态

}

return 0;

}

DWORD WINAPI Fun2Proc(

LPVOID lpParameter   // thread data

)

{

while(TRUE){

WaitForSingleObject(hMutex, INFINITE);

if (tickets > 0)

{

Sleep(1);

cout << "Thread2 sell tickets : " << tickets-- << endl;

}

else

break;

ReleaseMutex(hMutex);

}

return 0;

}

BOOL CChatDlg::InitSocket()

{

m_socket = socket(AF_INET, SOCK_DGRAM, 0);

if (INVALID_SOCKET == m_socket)

{

MessageBox("创建套接字失败!");

return FALSE;

}

SOCKADDR_IN addrSock;

addrSock.sin_addr.S_un.S_addr = htonl(INADDR_ANY);

addrSock.sin_family = AF_INET;

addrSock.sin_port = htons(6010);

int bindRst;

bindRst = bind(m_socket, (SOCKADDR*)&addrSock, sizeof(SOCKADDR));

if (SOCKET_ERROR == bindRst)

{

closesocket(m_socket);

MessageBox("绑定失败!");

return FALSE;

}

return TRUE;

}

DWORD WINAPI CChatDlg::RecvProc(LPVOID lpParameter)

{

//根据线程函数参数获取发送端套接字和要设置包含文本控件的窗口句柄

SOCKET socket = ((RECVPARAM*)lpParameter)->socket;

HWND hWnd = ((RECVPARAM*)lpParameter)->hWnd;//窗口句柄

SOCKADDR_IN addrRecv;

int len = sizeof(SOCKADDR);

char recvBuf[100];

char tempBuf[100];

int recvRst;

CString recvStr;

while(TRUE)

{

//接收数据

recvRst = recvfrom(socket, recvBuf, 100, 0, (SOCKADDR*)&addrRecv, &len);

if (SOCKET_ERROR == recvRst)

{

break;

}

sprintf(tempBuf, "%s说:%s\r\n", inet_ntoa(addrRecv.sin_addr), recvBuf);

//                recvStr += tempBuf;//这种方式更加简单不用使用消息

//                ::SetDlgItemText(hWnd, IDC_EDIT_RECV, recvStr);

//使用自定义消息的方式来对控件填充内容

::PostMessage(hWnd, WM_RECVDATA, 0, (LPARAM)tempBuf);

}

return 0;

}

InitSocket();//初始化套接字库

RECVPARAM *pRecvParm = new RECVPARAM();

pRecvParm->socket = m_socket;

pRecvParm->hWnd = m_hWnd;

HANDLE hThreadRecv = CreateThread(NULL, 0, RecvProc, (LPVOID)pRecvParm, 0, NULL);

CloseHandle(hThreadRecv);

void CChatDlg::OnRecvData(WPARAM wParam,LPARAM lParam)

{

CString str=(char*)lParam;

CString strTemp;

GetDlgItemText(IDC_EDIT_RECV,strTemp);

str+="\r\n";

str+=strTemp;

SetDlgItemText(IDC_EDIT_RECV,str);

}

void CChatDlg::OnBtnSend()

{

// TOD Add your control notification handler code here

DWORD dwIP;

((CIPAddressCtrl*)GetDlgItem(IDC_IPADDRESS1))->GetAddress(dwIP);

SOCKADDR_IN addrTo;

addrTo.sin_family=AF_INET;

addrTo.sin_port=htons(6000);

addrTo.sin_addr.S_un.S_addr=htonl(dwIP);

CString strSend;

GetDlgItemText(IDC_EDIT_SEND,strSend);

sendto(m_socket,strSend,strSend.GetLength()+1,0,

(SOCKADDR*)&addrTo,sizeof(SOCKADDR));

SetDlgItemText(IDC_EDIT_SEND,"");

}