blob: 2f214e29e5aada4f116cb0f603cb882c7e984266 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
|
// Licensed to the .NET Foundation under one or more agreements.
// The .NET Foundation licenses this file to you under the MIT license.
// See the LICENSE file in the project root for more information.
/*============================================================
**
** Source : test.c
**
** Purpose: InterlockedDecrement() function
**
** The test case spawns MAX_THREADS Threads, and each thread call InterlockedDecrement Function to decrement a
** global counter REPEAT_COUNT Times. The Test case sets the global counter to MAX_THREADS * REPEAT_COUNT
** at the begining of the test. The test cases passes if at the end the test the value of the global counter is Zero.
**
**
**=========================================================*/
#include <palsuite.h>
#define MAX_THREADS 64
#define REPEAT_COUNT 10000
LONG GlobalCounter = 0;
void DecrementCounter(void);
int __cdecl main(int argc, char *argv[])
{
LONG TotalOperations=0;
int i=0;
DWORD dwThreadID = 0;
HANDLE hThread[MAX_THREADS];
TotalOperations = MAX_THREADS * REPEAT_COUNT;
GlobalCounter = TotalOperations;
/*
* Initialize the PAL and return FAILURE if this fails
*/
if(0 != (PAL_Initialize(argc, argv)))
{
return FAIL;
}
//Create MAX_THREADS threads that will operate on the global counter
for (i=0;i<MAX_THREADS;i++)
{
hThread[i] = CreateThread(
NULL, // default security attributes
0, // use default stack size
(LPTHREAD_START_ROUTINE) DecrementCounter, // thread function
NULL, // argument to thread function
0, // use default creation flags
&dwThreadID); // returns the thread identifier
// Check the return value for success.
if (hThread[i] == NULL)
{
Fail("ERROR: Was not able to create thread\n"
"GetLastError returned %d\n", GetLastError());
}
}
//Wait for all threads to finish
for (i=0;i<MAX_THREADS;i++)
{
if (WAIT_OBJECT_0 != WaitForSingleObject (hThread[i], INFINITE))
{
Fail ("Main: Wait for Single Object failed. Failing test.\n"
"GetLastError returned %d\n", GetLastError());
}
}
/* Compare the value of global counter with zero.
*/
if (0!=GlobalCounter)
{
Fail("Test Case Failed: InterlockedDecrement \n");
}
PAL_Terminate();
return PASS;
}
void DecrementCounter(void)
{
int i=0;
for (i=0; i<REPEAT_COUNT;i++)
{
InterlockedDecrement(&GlobalCounter);
}
}
|
