diff options
| author | Martin v. Löwis <martin@v.loewis.de> | 2007-01-04 21:06:12 (GMT) |
|---|---|---|
| committer | Martin v. Löwis <martin@v.loewis.de> | 2007-01-04 21:06:12 (GMT) |
| commit | 7b7c9d420817e5ffb5fd3adbc19a9be4ba0f4604 (patch) | |
| tree | 8eaff650a7faf94527173b9b2029a262c57adee7 /Modules | |
| parent | 769a40a1d046baddbac4c01fa8feada2ee9e5207 (diff) | |
| download | cpython-7b7c9d420817e5ffb5fd3adbc19a9be4ba0f4604.zip cpython-7b7c9d420817e5ffb5fd3adbc19a9be4ba0f4604.tar.gz cpython-7b7c9d420817e5ffb5fd3adbc19a9be4ba0f4604.tar.bz2 | |
Bug #1566280: Explicitly invoke threading._shutdown from Py_Main,
to avoid relying on atexit.
Will backport to 2.5.
Diffstat (limited to 'Modules')
| -rw-r--r-- | Modules/main.c | 29 |
1 files changed, 29 insertions, 0 deletions
diff --git a/Modules/main.c b/Modules/main.c index 2224dfe..dc46d55 100644 --- a/Modules/main.c +++ b/Modules/main.c @@ -177,6 +177,33 @@ static int RunModule(char *module) return 0; } +/* Wait until threading._shutdown completes, provided + the threading module was imported in the first place. + The shutdown routine will wait until all non-daemon + "threading" threads have completed. */ +#include "abstract.h" +static void +WaitForThreadShutdown() +{ +#ifdef WITH_THREAD + PyObject *result; + PyThreadState *tstate = PyThreadState_GET(); + PyObject *threading = PyMapping_GetItemString(tstate->interp->modules, + "threading"); + if (threading == NULL) { + /* threading not imported */ + PyErr_Clear(); + return; + } + result = PyObject_CallMethod(threading, "_shutdown", ""); + if (result == NULL) + PyErr_WriteUnraisable(threading); + else + Py_DECREF(result); + Py_DECREF(threading); +#endif +} + /* Main program */ int @@ -514,6 +541,8 @@ Py_Main(int argc, char **argv) /* XXX */ sts = PyRun_AnyFileFlags(stdin, "<stdin>", &cf) != 0; + WaitForThreadShutdown(); + Py_Finalize(); #ifdef RISCOS if (Py_RISCOSWimpFlag) |