首页 > 代码库 > 面试题-多线程编程
面试题-多线程编程
题目:
四个线程 t1,t2,t3,t4,向 4 个文件中写入数据, t1 只能写入 1, t2 只能写入 2, t3 只能写
入 3, t4 只能写入 4,对 4 个文件 A, B, C, D 写入如下内容
A:123412341234.....
B:234123412341....
C:341234123412....
D:412341234123....
怎么实现同步可以让线程并行工作?
用windows c++实现.
// 222_thread.cpp : 定义控制台应用程序的入口点。//#include "stdafx.h"#include <windows.h>#include <thread>#include <iostream>using namespace std;HANDLE ghMutex;HANDLE handles[4][4];int idxx = 1;void threadA(){ int idx = 0; do { DWORD res = WaitForMultipleObjects(4, handles[0], false, INFINITE); WaitForSingleObject(ghMutex, INFINITE); switch (res) { case WAIT_OBJECT_0: cout << "A" ; SetEvent(handles[1][0]); break; case WAIT_OBJECT_0+1: cout << "B"; SetEvent(handles[1][1]); break; case WAIT_OBJECT_0+2: cout << "C"; SetEvent(handles[1][2]); break; case WAIT_OBJECT_0+3: cout << "D"; SetEvent(handles[1][3]); break; } cout << 1; idxx++; ReleaseMutex(ghMutex); } while (idxx < 50); }void threadB(){ int idx = 0; do { DWORD res = WaitForMultipleObjects(4, handles[1], false, INFINITE); WaitForSingleObject(ghMutex, INFINITE); switch (res) { case WAIT_OBJECT_0: cout << "A"; SetEvent(handles[2][0]); break; case WAIT_OBJECT_0 + 1: cout << "B"; SetEvent(handles[2][1]); break; case WAIT_OBJECT_0 + 2: cout << "C"; SetEvent(handles[2][2]); break; case WAIT_OBJECT_0 + 3: cout << "D"; SetEvent(handles[2][3]); break; } cout << 2; idxx++; ReleaseMutex(ghMutex); } while (idxx < 50);}void threadC(){ int idx = 0; do { DWORD res = WaitForMultipleObjects(4, handles[2], false, INFINITE); WaitForSingleObject(ghMutex, INFINITE); switch (res) { case WAIT_OBJECT_0: cout << "A"; SetEvent(handles[3][0]); break; case WAIT_OBJECT_0 + 1: cout << "B"; SetEvent(handles[3][1]); break; case WAIT_OBJECT_0 + 2: cout << "C"; SetEvent(handles[3][2]); break; case WAIT_OBJECT_0 + 3: cout << "D"; SetEvent(handles[3][3]); break; } cout << 3; idxx++; ReleaseMutex(ghMutex); } while (idxx < 50);}void threadD(){ int idx = 0; do { DWORD res = WaitForMultipleObjects(4, handles[3], false, INFINITE); WaitForSingleObject(ghMutex, INFINITE); switch (res) { case WAIT_OBJECT_0: cout << "A"; SetEvent(handles[0][0]); break; case WAIT_OBJECT_0 + 1: cout << "B"; SetEvent(handles[0][1]); break; case WAIT_OBJECT_0 + 2: cout << "C"; SetEvent(handles[0][2]); break; case WAIT_OBJECT_0 + 3: cout << "D"; SetEvent(handles[0][3]); break; } cout << 4; idxx++; ReleaseMutex(ghMutex); } while (idxx < 50);}void WriteA(){ SetEvent(handles[0][0]);}void WriteB(){ SetEvent(handles[1][1]);}void WriteC(){ SetEvent(handles[2][2]);}void WriteD(){ SetEvent(handles[3][3]);}int _tmain(int argc, _TCHAR* argv[]){ /* file A file B file C file D thread 1 handle[0][0] handle[0][1] handle[0][2] handle[0][3] thread 2 handle[1][0] handle[1][1] handle[1][2] handle[1][3] thread 3 handle[2][0] handle[2][1] handle[2][2] handle[2][3] thread 4 handle[3][0] handle[3][1] handle[3][2] handle[3][3] */ for (int i = 0; i < 4; i++) { for (int j = 0; j < 4; j++) { handles[i][j] = CreateEvent(NULL, false, false, NULL); } } DWORD threadID; CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)threadA, NULL, 0, &threadID); CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)threadB, NULL, 0, &threadID); CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)threadC, NULL, 0, &threadID); CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)threadD, NULL, 0, &threadID); CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)WriteA, NULL, 0, &threadID); CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)WriteB, NULL, 0, &threadID); CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)WriteC, NULL, 0, &threadID); CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)WriteD, NULL, 0, &threadID); ghMutex = CreateMutex( NULL, // default security attributes FALSE, // initially not owned NULL); // unnamed mutex if (ghMutex == NULL) { printf("CreateMutex error: %d\n", GetLastError()); return 1; } Sleep(60000); return 0;}
面试题-多线程编程
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。