FazBrowse GitHub Viewer
|
Trending
|
URL:
|
Home
Tools:
[Download Repo ZIP]
[View Raw Code]
[Original HTTPS Page]
pythonnet/src/embed_tests/TestInterrupt.cs at v3.2.0 · pythonnet/pythonnet · GitHub
pythonnet
pythonnet
Repository navigation
Code
Issues
147
(147)
Pull requests
11
(11)
Discussions
Actions
Projects
Wiki
Security and quality
Insights
Expand file tree
Breadcrumbs
pythonnet
/
src
/
embed_tests
/
TestInterrupt.cs
Copy path
More file actions
More file actions
Latest commit
History
History
History
106 lines (90 loc) · 3.65 KB
Breadcrumbs
pythonnet
/
src
/
embed_tests
/
TestInterrupt.cs
Copy path
File metadata and controls
106 lines (90 loc) · 3.65 KB
Raw
Copy raw file
Download raw file
Open symbols panel
Edit and raw actions
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
95
96
97
98
99
100
101
102
103
104
105
106
using
System
;
using
System
.
Diagnostics
;
using
System
.
Threading
;
using
System
.
Threading
.
Tasks
;
using
NUnit
.
Framework
;
using
Python
.
Runtime
;
namespace
Python
.
EmbeddingTest
{
public
class
TestInterrupt
{
PyObject
threading
;
[
OneTimeSetUp
]
public
void
SetUp
(
)
{
// workaround for assert tlock.locked() warning
threading
=
Py
.
Import
(
"threading"
)
;
}
[
OneTimeTearDown
]
public
void
Dispose
(
)
{
threading
.
Dispose
(
)
;
}
[
Test
]
public
void
PythonThreadIDStable
(
)
{
long
pythonThreadID
=
0
;
long
pythonThreadID2
=
0
;
var
asyncCall
=
Task
.
Factory
.
StartNew
(
(
)
=>
{
using
(
Py
.
GIL
(
)
)
{
Interlocked
.
Exchange
(
ref
pythonThreadID
,
(
long
)
PythonEngine
.
GetPythonThreadID
(
)
)
;
Interlocked
.
Exchange
(
ref
pythonThreadID2
,
(
long
)
PythonEngine
.
GetPythonThreadID
(
)
)
;
}
}
)
;
var
timeout
=
Stopwatch
.
StartNew
(
)
;
IntPtr
threadState
=
PythonEngine
.
BeginAllowThreads
(
)
;
while
(
Interlocked
.
Read
(
ref
pythonThreadID
)
==
0
||
Interlocked
.
Read
(
ref
pythonThreadID2
)
==
0
)
{
Assert
.
Less
(
timeout
.
Elapsed
,
TimeSpan
.
FromSeconds
(
5
)
,
"thread IDs were not assigned in time"
)
;
}
PythonEngine
.
EndAllowThreads
(
threadState
)
;
Assert
.
That
(
asyncCall
.
Wait
(
TimeSpan
.
FromSeconds
(
5
)
)
,
Is
.
True
,
"Async thread has not finished in time"
)
;
Assert
.
That
(
pythonThreadID2
,
Is
.
EqualTo
(
pythonThreadID
)
)
;
Assert
.
NotZero
(
pythonThreadID
)
;
}
[
Test
]
public
void
InterruptTest
(
)
{
long
pythonThreadID
=
0
;
var
asyncCall
=
Task
.
Factory
.
StartNew
(
(
)
=>
{
using
(
Py
.
GIL
(
)
)
{
Interlocked
.
Exchange
(
ref
pythonThreadID
,
(
long
)
PythonEngine
.
GetPythonThreadID
(
)
)
;
return
PythonEngine
.
RunSimpleString
(
@"
try:
import time
while True:
time.sleep(0.2)
except KeyboardInterrupt:
pass"
)
;
}
}
)
;
var
timeout
=
Stopwatch
.
StartNew
(
)
;
IntPtr
threadState
=
PythonEngine
.
BeginAllowThreads
(
)
;
while
(
Interlocked
.
Read
(
ref
pythonThreadID
)
==
0
)
{
Assert
.
Less
(
timeout
.
Elapsed
,
TimeSpan
.
FromSeconds
(
5
)
,
"thread ID was not assigned in time"
)
;
}
PythonEngine
.
EndAllowThreads
(
threadState
)
;
int
interruptReturnValue
=
PythonEngine
.
Interrupt
(
(
ulong
)
Interlocked
.
Read
(
ref
pythonThreadID
)
)
;
Assert
.
That
(
interruptReturnValue
,
Is
.
EqualTo
(
1
)
)
;
threadState
=
PythonEngine
.
BeginAllowThreads
(
)
;
Assert
.
That
(
asyncCall
.
Wait
(
TimeSpan
.
FromSeconds
(
5
)
)
,
Is
.
True
,
"Async thread was not interrupted in time"
)
;
PythonEngine
.
EndAllowThreads
(
threadState
)
;
// On free-threaded CPython 3.14, PyRun_SimpleString may return -1 even
// when the script catches the async-injected KeyboardInterrupt — the
// C-level error indicator depends on which bytecode boundary the
// async-exc fires at, and isn't always cleared the way GIL builds clear
// it. The interrupt firing and the script terminating cleanly are what
// this test exercises; the return code is a side-effect that's only
// deterministic under the GIL.
if
(
Python
.
Runtime
.
Native
.
ABI
.
IsFreeThreaded
)
Assert
.
That
(
asyncCall
.
Result
,
Is
.
AnyOf
(
0
,
-
1
)
)
;
else
Assert
.
That
(
asyncCall
.
Result
,
Is
.
EqualTo
(
0
)
)
;
}
}
}
Back
|
FazBrowse Home
|
New Git URL