blob: 16c4e50e617d9723e93bae2d35ea1003135477b5 (
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
|
// 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.
using System;
using System.Threading;
// This is a non-9x test.
class WaitAnyEx
{
WaitHandle[] wh;
public static int Main()
{
WaitAnyEx wae = new WaitAnyEx();
return wae.Run();
}
private int Run()
{
int iRet = -1;
Console.WriteLine("Abandoning only one Mutex in array " +
"with other WaitHandles, signaling other mutexes");
CreateArray(64);
Thread t = new Thread(new ThreadStart(this.AbandonOneAndRelease));
t.Start();
t.Join();
int i = -1;
try
{
Console.WriteLine("Waiting...");
i = WaitHandle.WaitAny(wh);
Console.WriteLine("WaitAny did not throw AbandonedMutexExcpetion");
}
catch(AbandonedMutexException)
{
// Expected
iRet = 100;
}
catch(Exception e)
{
Console.WriteLine("Unexpected exception thrown: " +
e.ToString());
}
Console.WriteLine(100 == iRet ? "Test Passed" : "Test Failed");
return iRet;
}
private void AbandonOneAndRelease()
{
Mutex m = new Mutex();
bool bSet = false;
foreach(WaitHandle w in wh)
{
if(w.GetType() == m.GetType())
{
w.WaitOne();
if(bSet)
((Mutex)w).ReleaseMutex();
bSet = true;
}
}
}
private void CreateArray(int numElements)
{
wh = new WaitHandle[numElements];
for(int i=0;i<numElements;i++)
{
switch(i%3)
{
case 0:
wh[i] = new ManualResetEvent(false);
break;
case 1:
wh[i] = new Mutex();
break;
case 2:
wh[i] = new Semaphore(0,5);
break;
}
}
}
}
|
