学步园

环境VC6.0

demo1:

#include "stdafx.h"
#include <windows.h>
#include <iostream.h>
 
UINT ComputeProc(int *i);/*线程函数头*/
 
int main(int argc, char* argv[])
{
    int j=0;
    HANDLE hThread1;
    HANDLE hThread2;
    hThread1=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)ComputeProc,&j,0,NULL);/*创建线程，其中第四个参数是LPVOID lpParameter，不限制类型的指针参数*/
    j++;
    hThread2=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)ComputeProc,&j,0,NULL);
    Sleep(2000);
    TerminateThread(hThread1,1);
    TerminateThread(hThread2,1);
    CloseHandle(hThread1);
    CloseHandle(hThread2);
    return 0;
}
 
UINT ComputeProc(int *i)
{
    int k=*i;
    printf("The result is %d. \n",k);/*从输出可以看到子线程和父线程是同时运行的*/
    return 0;
}

demo2:

//这是2个线程模拟卖火车票的小程序
#include <windows.h>
#include <iostream.h>

DWORD WINAPI Fun1Proc(LPVOID lpParameter);//thread data
DWORD WINAPI Fun2Proc(LPVOID lpParameter);//thread data

int index=0;
int tickets=10;
HANDLE hMutex;
void main()
{
    HANDLE hThread1;
    HANDLE hThread2;
    //创建线程

    hThread1=CreateThread(NULL,0,Fun1Proc,NULL,0,NULL);
    hThread2=CreateThread(NULL,0,Fun2Proc,NULL,0,NULL);
    CloseHandle(hThread1);
    CloseHandle(hThread2);

    //创建互斥对象
    hMutex=CreateMutex(NULL,TRUE,"tickets");
    if (hMutex)
    {
        if (ERROR_ALREADY_EXISTS==GetLastError())
        {
            cout<<"only one instance can run!"<<endl;
            return;
        }
    }
    WaitForSingleObject(hMutex,INFINITE);
    ReleaseMutex(hMutex);
    ReleaseMutex(hMutex);
    
    Sleep(4000);
}
//线程1的入口函数
DWORD WINAPI Fun1Proc(LPVOID lpParameter)//thread data
{
    while (true)
    {
        ReleaseMutex(hMutex);
        WaitForSingleObject(hMutex,INFINITE);
        if (tickets>0)
        {
            Sleep(1);
            cout<<"thread1 sell ticket :"<<tickets--<<endl;
        }
        else
            break;
        ReleaseMutex(hMutex);
    }

    return 0;
}
//线程2的入口函数
DWORD WINAPI Fun2Proc(LPVOID lpParameter)//thread data
{
    while (true)
    {
        ReleaseMutex(hMutex);
        WaitForSingleObject(hMutex,INFINITE);
        if (tickets>0)
        {
            Sleep(1);
            cout<<"thread2 sell ticket :"<<tickets--<<endl;
        }
        else
            break;
        ReleaseMutex(hMutex);
    }
    
    return 0;
}