MultiThread Windows

Bonjour,

J'essaie de trouver l'avantage =E0 utiliser des threads. Pour cel=E0 j'ai
fait un programme qui chronom=E8tre l'execution d'une fonction d'une
mani=E8re classique puis =E0 l'aide de threads (de 1 =E0 N) Je m'attendais
pour N=3D2 (ayant un Dual Core) =E0 avoir un gain de temps. Pas =E9norme
mais tout de m=EAme sensible. Ce n'est absolument pas le cas. Pour N=3D2
le programme met 2 fois plus de temps et d'une mani=E8re g=E9n=E9rale pour
N, il met N fois plus de temps.

Voici la fonction :

DWORD WINAPI ThreadFunc(LPVOID lpParam )
{
unsigned int i,j;

for(i=3D0;i<=3D2000000000;i++)
j+=3Di;
return 0;
}

Je me suis donc dit bigre ! peut =EAtre que je monopolise les registres
et les acc=E8s m=E9moires pour chaque fois la m=EAme chose. Le Dual Core est
un faux biprocesseur. J'ai donc chronom=E8tr=E9 l'execution s=E9quentielle
puis paral=E8lle de deux fonctions tr=E8s diff=E9rentes.

DWORD WINAPI ThreadFunc1(LPVOID lpParam )
{
unsigned int i;
char *buff;

for(i=3D0;i<=3D200000;i++)
{
buff=3Dcalloc(1000000,4);
free(buff);
}
return 0;
}

DWORD WINAPI ThreadFunc2(LPVOID lpParam )
{
unsigned int i,j;

for(i=3D0;i<=3D2000000000;i++)
j+=3Di;
return 0;
}

L'une compte, l'autre alloue de la m=E9moire. Effectivement les
r=E9sultats sont prometteurs, le Dual Core s'en sort bien. Ma question
est donc la suivante : j'ai un programme qui contient une zone
critique appel=E9e 1 million de fois. Elle est compos=E9e d'une allocation
et de tests m=E9moires brutaux. Elle est pure dans le sens o=F9 les
variables ont les m=EAmes valeurs en sortie qu'en entr=E9e. Elle n'utilise
pas de variable globale. Quel est l'int=E9r=EAt d'en faire un thread et
l'appeler 2 fois si elle va monopoliser les m=EAmes ressources
syst=E8mes ? Par exemple comment parall=E9liser une fonction r=E9cursive ?

Merci :)
Et pi de la doc serait aussi la bienvenue, je suis newbie dans le
domaine Windows/Createthread et tutti quanti. Ce que je trouve est
soit trop simple, soit trop th=E9orique. Rien de concr=EAt.

--------------------------------------------
(pour info : le code source avec une seule fonction, puis la version
avec deux fonctions)

#include <windows.h>
#include <stdio.h>
#include <stdlib.h>
#include <time.h>

DWORD WINAPI ThreadFunc(LPVOID lpParam )
{
unsigned int i,j;

for(i=3D0;i<=3D2000000000;i++)
j+=3Di;
return 0;
}

int main(char argc,char **argv)
{
int NB;
DWORD dwThreadId,dwThrdParam=3D1,pWait;
HANDLE hThread[NB];
int i;
clock_t endclock,startclock;

if(argc!=3D2)
exit(0);
NB=3Datoi(argv[1]);

startclock=3Dendclock=3Dclock();
ThreadFunc(NULL);
endclock=3Dclock();
printf("%f\n",(float)(endclock-startclock)/(float)CLOCKS_PER_SEC);
for(i=3D0;i<NB;i++)
hThread[i]=3DNULL;
for(i=3D0;i<NB;i++)
if(!(hThread[i]=3DCreateThread(NULL,
10,ThreadFunc,NULL,CREATE_SUSPENDED,&dwThreadId)))
break;
printf("%d threads\n",i);
startclock=3Dendclock=3Dclock();

for(i=3D0;i<NB;i++)
SetThreadPriority(hThread[i],15);
for(i=3D0;i<NB;i++)
ResumeThread(hThread[i]);
SetThreadPriority(GetCurrentThread(),-15);
for(i=3D0;i<NB;i++)
if(hThread[i])
{
pWait=3DWaitForSingleObject(hThread[i],INFINITE);
if(pWait=3D=3DWAIT_OBJECT_0)
CloseHandle(hThread[i]);
}
endclock=3Dclock();
printf("%f\n",(float)(endclock-startclock)/(float)
(i*CLOCKS_PER_SEC));
}
------------------------------------


#include <windows.h>
#include <stdio.h>
#include <stdlib.h>
#include <time.h>

DWORD WINAPI ThreadFunc1(LPVOID lpParam )
{
unsigned int i;
char *buff;

for(i=3D0;i<=3D200000;i++)
{
buff=3Dcalloc(1000000,4);
free(buff);
}
return 0;
}

DWORD WINAPI ThreadFunc2(LPVOID lpParam )
{
unsigned int i,j;

for(i=3D0;i<=3D2000000000;i++)
j+=3Di;
return 0;
}

int main(char argc,char **argv)
{
int NB;

if(argc!=3D2)
exit(0);
NB=3Datoi(argv[1])<<1;

DWORD dwThreadId,dwThrdParam=3D1,pWait;
HANDLE hThread[NB];
int i;
clock_t endclock,startclock;

startclock=3Dclock();
ThreadFunc1(NULL);
ThreadFunc2(NULL);
endclock=3Dclock();
printf("%f\n",(float)(endclock-startclock)/(float)CLOCKS_PER_SEC);
for(i=3D0;i<NB;i++)
hThread[i]=3DNULL;
for(i=3D0;i<NB;)
{
if(!(hThread[i++]=3DCreateThread(NULL,
10,ThreadFunc1,NULL,CREATE_SUSPENDED,&dwThreadId)))
break;
if(!(hThread[i++]=3DCreateThread(NULL,
10,ThreadFunc2,NULL,CREATE_SUSPENDED,&dwThreadId)))
break;
}
printf("%d threads\n",i);
startclock=3Dclock();
for(i=3D0;i<NB;i++)
SetThreadPriority(hThread[i],15);
for(i=3D0;i<NB;i++)
printf("pri:%d\n",GetThreadPriority(hThread[i]));
for(i=3D0;i<NB;i++)
ResumeThread(hThread[i]);
SetThreadPriority(GetCurrentThread(),-15);
pWait=3DWaitForMultipleObjects(i,hThread,TRUE,INFINITE);
endclock=3Dclock();
for(i=3D0;i<NB;i++)
if(hThread[i])
{
if(pWait=3D=3DWAIT_OBJECT_0)
CloseHandle(hThread[i]);
}
printf("%f\n",(float)(endclock-startclock)/(float)
(i*CLOCKS_PER_SEC));
}