Skip to content

Fix memory leak add pyobject finalizer #27

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
jaredbroad merged 20 commits into from
Mar 28, 2019
Merged

Fix memory leak add pyobject finalizer #27

Changes from 1 commit
Commits
Show all changes
20 commits
Select commit Hold shift + click to select a range
26e88d7
Finalizer for PyObject
amos402 Jun 23, 2018
fccd1d8
Avoid test interdependency
amos402 Jun 24, 2018
9281157
Add source to .csproj
amos402 Jun 24, 2018
481cb4f
Make sure recover the environment
amos402 Jun 24, 2018
1959a6a
Add StackTrace of C# exception
amos402 Jun 24, 2018
e7b8635
Clean up the test and interface
amos402 Jun 24, 2018
c51cebd
Update CHANGELOG.md
amos402 Jun 24, 2018
833d367
Add links to issues and PRs in CHANGELOG
civilx64 Jul 1, 2018
9aa9b1a
Mono doesn't have GC.WaitForFullGCComplete
amos402 Jun 24, 2018
338dcc1
Fixed PythonException leak
amos402 Jun 25, 2018
ef832a3
Fixed nPython.exe crash on Shutdown
amos402 Jul 10, 2018
3a9be30
Add error handler
amos402 Aug 4, 2018
eb569f2
Make collect callback without JIT
amos402 Sep 6, 2018
994449e
Add pending marker
amos402 Oct 23, 2018
fc53d94
Remove PYTHONMALLOC setting
amos402 Oct 25, 2018
8eb3591
Fix ref count error
amos402 Nov 22, 2018
3610220
Add ref count check for helping discover the bugs of decref too much
amos402 Nov 22, 2018
e4fd72e
Fix ref count error
amos402 Nov 25, 2018
0ed8bee
typo error
amos402 Nov 26, 2018
2c94c90
Version bump 1.0.5.18
Martin-Molinero Mar 27, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Avoid test interdependency
  • Loading branch information
@amos402 @Martin-Molinero
amos402 authored and Martin-Molinero committed Mar 27, 2019
commit fccd1d874f6ade3490cb8597ee42d0dc526e7f86
101 changes: 55 additions & 46 deletions src/embed_tests/TestPyScope.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -293,24 +293,27 @@ public void TestImportScopeByName()
[Test]
public void TestVariables()
{
(ps.Variables() as dynamic)["ee"] = new PyInt(200);
var a0 = ps.Get<int>("ee");
Assert.AreEqual(200, a0);
using (Py.GIL())
{
(ps.Variables() as dynamic)["ee"] = new PyInt(200);
var a0 = ps.Get<int>("ee");
Assert.AreEqual(200, a0);

ps.Exec("locals()['ee'] = 210");
var a1 = ps.Get<int>("ee");
Assert.AreEqual(210, a1);
ps.Exec("locals()['ee'] = 210");
var a1 = ps.Get<int>("ee");
Assert.AreEqual(210, a1);

ps.Exec("globals()['ee'] = 220");
var a2 = ps.Get<int>("ee");
Assert.AreEqual(220, a2);
ps.Exec("globals()['ee'] = 220");
var a2 = ps.Get<int>("ee");
Assert.AreEqual(220, a2);

using (var item = ps.Variables())
{
item["ee"] = new PyInt(230);
using (var item = ps.Variables())
{
item["ee"] = new PyInt(230);
}
var a3 = ps.Get<int>("ee");
Assert.AreEqual(230, a3);
}
var a3 = ps.Get<int>("ee");
Assert.AreEqual(230, a3);
}

/// <summary>
Expand All @@ -324,49 +327,55 @@ public void TestThread()
//should be removed.
dynamic _ps = ps;
var ts = PythonEngine.BeginAllowThreads();
using (Py.GIL())
{
_ps.res = 0;
_ps.bb = 100;
_ps.th_cnt = 0;
//add function to the scope
//can be call many times, more efficient than ast
ps.Exec(
"def update():\n" +
" global res, th_cnt\n" +
" res += bb + 1\n" +
" th_cnt += 1\n"
);
}
int th_cnt = 3;
for (int i =0; i< th_cnt; i++)
try
{
System.Threading.Thread th = new System.Threading.Thread(()=>
using (Py.GIL())
{
_ps.res = 0;
_ps.bb = 100;
_ps.th_cnt = 0;
//add function to the scope
//can be call many times, more efficient than ast
ps.Exec(
"def update():\n" +
" global res, th_cnt\n" +
" res += bb + 1\n" +
" th_cnt += 1\n"
);
}
int th_cnt = 3;
for (int i = 0; i < th_cnt; i++)
{
System.Threading.Thread th = new System.Threading.Thread(() =>
{
using (Py.GIL())
{
//ps.GetVariable<dynamic>("update")(); //call the scope function dynamicly
_ps.update();
}
});
th.Start();
}
//equivalent to Thread.Join, make the main thread join the GIL competition
int cnt = 0;
while (cnt != th_cnt)
{
using (Py.GIL())
{
//ps.GetVariable<dynamic>("update")(); //call the scope function dynamicly
_ps.update();
cnt = ps.Get<int>("th_cnt");
}
});
th.Start();
}
//equivalent to Thread.Join, make the main thread join the GIL competition
int cnt = 0;
while(cnt != th_cnt)
{
System.Threading.Thread.Sleep(10);
}
using (Py.GIL())
{
cnt = ps.Get<int>("th_cnt");
var result = ps.Get<int>("res");
Assert.AreEqual(101 * th_cnt, result);
}
System.Threading.Thread.Sleep(10);
}
using (Py.GIL())
finally
{
var result = ps.Get<int>("res");
Assert.AreEqual(101* th_cnt, result);
PythonEngine.EndAllowThreads(ts);
}
PythonEngine.EndAllowThreads(ts);
}
}
}