Mutax

[Watch0ut]

Добрый день,
Я разбираюсь с мьютаксами, и не могу понять в чем проблема в моей программе. Задача - создать связный список из четных и нечетных чисел в 2 потока, числа должны идти по порядку. Если просто выводить в консоль через cout << " " << j; , работает как надо... а при использовании списка не получается. Если добавить задержку после ReleaseMutex получается более менее упорядочено, но все равно не так. Подскажите в чем проблема и как это исправить используя только мьютаксы?

#include "stdafx.h"
#include <iostream>
#include <windows.h>
#include <stdio.h>


using namespace std;

HANDLE tw,tr;
HANDLE Mutex;

unsigned long tw_id, tr_id;

struct ListItem {  
	int value; // данные
	ListItem *next; // указатель на следующий элемент структуры

	ListItem (int i, ListItem *n = NULL) // конструктор структуры, по умолчанию n = Null
		{
		 value = i;
		 next = n;
		}
				};

	ListItem *first; // указатель на первый элемент списка
	ListItem *last; // указатель на последний элемент списка
	ListItem *p;

	void AddNode(int value) {

  ListItem *p = new  ListItem (value);
  p->value=value;
  if (first == NULL) 
  {
    p->next = NULL;
    first = p;
    last = p;
  }
  else
  {
    p->next = NULL;
    last->next = p;
    last = p;
  }
	                   }

	void PrintList()
	{
	  p = first;
	  while (p != NULL) 
		{
			cout << " " << p->value;
			p =p->next;
		}
  	}




void thread1(){
	
	int j;
	for (int i =0; i<50;i++)
	{
		WaitForSingleObject(Mutex,INFINITE);

			
		j = 2*i;
		AddNode(j);
		//cout << " " << j;
	    ReleaseMutex( Mutex );
		//Sleep(10);
	}
			}

void thread2(){

	int j;
	for (int i =0; i<50;i++)
	{
		WaitForSingleObject(Mutex, INFINITE);
		j = 2*i+1;
	    AddNode(j);
	//   cout << " " << j;
		ReleaseMutex(Mutex);
	//	Sleep(10);
		
}
	
}
int main( void )
{ 
	Mutex = CreateMutex (NULL , FALSE, NULL);
	tw=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)thread1,NULL,0,&tw_id);
	tr=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)thread2,NULL,0,&tr_id);
	
	Sleep(1000);

	PrintList();
	cin.get();
return 0;
}

[Lasor]

Сообщение от Watch0ut

Добрый день,
Я разбираюсь с мьютаксами, и не могу понять в чем проблема в моей программе. Задача - создать связный список из четных и нечетных чисел в 2 потока, числа должны идти по порядку. Если просто выводить в консоль через cout << " " << j; , работает как надо... а при использовании списка не получается. Если добавить задержку после ReleaseMutex получается более менее упорядочено, но все равно не так. Подскажите в чем проблема и как это исправить используя только мьютаксы?

#include "stdafx.h"
#include <iostream>
#include <windows.h>
#include <stdio.h>


using namespace std;

HANDLE tw,tr;
HANDLE Mutex;

unsigned long tw_id, tr_id;

struct ListItem {  
	int value; // данные
	ListItem *next; // указатель на следующий элемент структуры

	ListItem (int i, ListItem *n = NULL) // конструктор структуры, по умолчанию n = Null
		{
		 value = i;
		 next = n;
		}
				};

	ListItem *first; // указатель на первый элемент списка
	ListItem *last; // указатель на последний элемент списка
	ListItem *p;

	void AddNode(int value) {

  ListItem *p = new  ListItem (value);
  p->value=value;
  if (first == NULL) 
  {
    p->next = NULL;
    first = p;
    last = p;
  }
  else
  {
    p->next = NULL;
    last->next = p;
    last = p;
  }
	                   }

	void PrintList()
	{
	  p = first;
	  while (p != NULL) 
		{
			cout << " " << p->value;
			p =p->next;
		}
  	}




void thread1(){
	
	int j;
	for (int i =0; i<50;i++)
	{
		WaitForSingleObject(Mutex,INFINITE);

			
		j = 2*i;
		AddNode(j);
		//cout << " " << j;
	    ReleaseMutex( Mutex );
		//Sleep(10);
	}
			}

void thread2(){

	int j;
	for (int i =0; i<50;i++)
	{
		WaitForSingleObject(Mutex, INFINITE);
		j = 2*i+1;
	    AddNode(j);
	//   cout << " " << j;
		ReleaseMutex(Mutex);
	//	Sleep(10);
		
}
	
}
int main( void )
{ 
	Mutex = CreateMutex (NULL , FALSE, NULL);
	tw=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)thread1,NULL,0,&tw_id);
	tr=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)thread2,NULL,0,&tr_id);
	
	Sleep(1000);

	PrintList();
	cin.get();
return 0;
}

Делай mutex.lock/mutex.unlock. После unlock делай usleep(1) - отпускай поток. Не отпустив его ты не даёшь другому потоку работать.