Question

读者写者问题：读者优先，允许多个读者同时读，但只允许一个写者写

#include<windows.h>
#include<iostream>
using namespace std;
int readercount=0;
HANDLE r,w;
CRITICAL_SECTION cs;
DWORD WINAPI writer(PVOID pArg){
int ww=(int)pArg;
DWORD t;
while(true){
t=WaitForSingleObject(w,1);
if(t==WAIT_TIMEOUT)
{
EnterCriticalSection(&cs);
cout<<"writer "<<ww<<" waite to read...."<<endl;
LeaveCriticalSection(&cs);
WaitForSingleObject(w,INFINITE);
}
EnterCriticalSection(&cs);
cout<<"writer "<<ww<<" start to write...."<<endl;
LeaveCriticalSection(&cs);
Sleep(3000);
EnterCriticalSection(&cs);
cout<<"writer "<<ww<<" finish writing...."<<endl;
LeaveCriticalSection(&cs);
Sleep(5000);
ReleaseSemaphore(w, 1, NULL);
}
return 0;
}
DWORD WINAPI reader(PVOID pArg){
int rr=(int)pArg;
DWORD t;
while(true){
readercount++;
if(readercount==1)
{
t=WaitForSingleObject(w,1);
if(t==WAIT_TIMEOUT)
{
EnterCriticalSection(&cs);
cout<<" reader "<<rr<<" waite to read...."<<endl;
LeaveCriticalSection(&cs);
WaitForSingleObject(w,INFINITE);
}
}
EnterCriticalSection(&cs);
cout<<" reader "<<rr<<" start to read...."<<endl;
LeaveCriticalSection(&cs);
Sleep(3000);
EnterCriticalSection(&cs);
cout<<" reader "<<rr<<" finish reading...."<<endl;
LeaveCriticalSection(&cs);
Sleep(5000);
readercount--;
if(readercount==0)
ReleaseSemaphore(w, 1, NULL);
}
return 0;
}
int main(){
int i;
InitializeCriticalSection(&cs);
w = CreateSemaphore(NULL, 1, 1, NULL);
HANDLE Thread[6];
for(i=0;i<3;i++)
Thread[i]=CreateThread(NULL,0,reader,(LPVOID)(i+1),0,NULL);
for(i=3;i<5;i++)
Thread[i]=CreateThread(NULL,0,writer,(LPVOID)(i-2),0,NULL);
WaitForMultipleObjects(5, Thread, TRUE, INFINITE);
CloseHandle(r);
DeleteCriticalSection(&cs);
return 0;
}

Answer 1

编译能够通过吧，就是看调试运行是否与期望一样。

如果你觉得我的回答比较满意，希望给个采纳鼓励我！不满意可以继续追问。

追问

编译可以，但是总是读者在读，没有写者的事

追答

是这样啊，我再仔细研究一下。你的意思是找出症结所在并加以修改？

追问

对呀，我的代码有问题

追答

主程序中写调用：for(i=3;i<5;i++)……

是否应为：for(i=3;i<6;i++)Thread[i]=CreateThread(NULL,0,writer,(LPVOID)(i-1),0,NULL);

追问

有3个读者，2个写者，我把HANDLE Thread[6]改成 HANDLE Thread[5]了。结果：

其中写者根本没有进行写操作

追答

读者优先，写的时候可以读否？写者在等候却没有权力进入，应当是写程序设计不当。我再分析一下。

追问

只允许一个写者在写，有写者的时候读者不能读，另一个写者也不能写。但允许多个读者同时读，有读者的时候不允许写者写。

追答

另外我发现读写的时候，sleep时间是3000，读写完毕后sleep时间是5000，建议将这两个时间值互换一下，减少writer等候时间。还有一点疑问：读程序中，
t=WaitForSingleObject(w,1);/*参数w是否应改为r*/
if(t==WAIT_TIMEOUT)
{
EnterCriticalSection(&cs);
cout<<" reader "<<rr<<" waite to read...."<<endl;
LeaveCriticalSection(&cs);
WaitForSingleObject(w,INFINITE);/*参数w是否应改为r*/ }
}
EnterCriticalSection(&cs);
cout<<" reader "<<rr<<" start to read...."<<endl;
LeaveCriticalSection(&cs);
Sleep(3000);
EnterCriticalSection(&cs);
cout<<" reader "<<rr<<" finish reading...."<<endl;
LeaveCriticalSection(&cs);
Sleep(5000);
readercount--;
if(readercount==0)
ReleaseSemaphore(w, 1, NULL);/*参数w是否应改为r*/

追问

改成r之后那读程序和写程序就没有关系了，就可以同时进行了，结果：

追答

怎么会没有关系呢？你注意观察输出结果，不是有writer 2 wait to read……
以及writer 1 waite to read ……吗？

追问

那他们就可以同时读写了，我上传你看一下writer1开始写，读者1、2、3也开始读，这不符合规则的

追答

嗯，这里的确有点违背设计要求。那么需要在读开始前还有附加一个条件：
即while(true){
{
EnterCriticalSection(&cs);
cout<<" reader "<<rr<<" waite to read...."<<endl;
LeaveCriticalSection(&cs);
WaitForSingleObject(w,INFINITE);
readercount++;
if(readercount==1)

追问

那你能把你运行正确的代码发过来吗？正确结果：

追答

邮箱或者私信，追答超出运行值。

Answer 2

完全不知道在说什么...
而且，写者应该成为作者才对吧

Answer 3

看不懂，有中文吗？

追问

什么中文？