summaryrefslogtreecommitdiff
path: root/Python/thread_nt.h
diff options
context:
space:
mode:
authorAndrew MacIntyre <andymac@bullseye.apana.org.au>2006-06-04 12:31:09 +0000
committerAndrew MacIntyre <andymac@bullseye.apana.org.au>2006-06-04 12:31:09 +0000
commit6539d2d3c758b507f10779e218d52d6c9f355025 (patch)
treed3677cd901f44e2341a50be45d8a3d2f6d1f4da6 /Python/thread_nt.h
parent7a071939d96702e13c377a5e7f87df7bf20391e5 (diff)
downloadcpython-git-6539d2d3c758b507f10779e218d52d6c9f355025.tar.gz
Patch #1454481: Make thread stack size runtime tunable.
Diffstat (limited to 'Python/thread_nt.h')
-rw-r--r--Python/thread_nt.h36
1 files changed, 35 insertions, 1 deletions
diff --git a/Python/thread_nt.h b/Python/thread_nt.h
index 5141053b03..8f5f996b46 100644
--- a/Python/thread_nt.h
+++ b/Python/thread_nt.h
@@ -185,7 +185,7 @@ PyThread_start_new_thread(void (*func)(void *), void *arg)
if (obj.done == NULL)
return -1;
- rv = _beginthread(bootstrap, 0, &obj); /* use default stack size */
+ rv = _beginthread(bootstrap, _pythread_stacksize, &obj);
if (rv == (Py_uintptr_t)-1) {
/* I've seen errno == EAGAIN here, which means "there are
* too many threads".
@@ -313,3 +313,37 @@ void PyThread_release_lock(PyThread_type_lock aLock)
if (!(aLock && LeaveNonRecursiveMutex((PNRMUTEX) aLock)))
dprintf(("%ld: Could not PyThread_release_lock(%p) error: %l\n", PyThread_get_thread_ident(), aLock, GetLastError()));
}
+
+/* minimum/maximum thread stack sizes supported */
+#define THREAD_MIN_STACKSIZE 0x8000 /* 32kB */
+#define THREAD_MAX_STACKSIZE 0x10000000 /* 256MB */
+
+/* set the thread stack size.
+ * Return 1 if an exception is pending, 0 otherwise.
+ */
+static int
+_pythread_nt_set_stacksize(size_t size)
+{
+ /* set to default */
+ if (size == 0) {
+ _pythread_stacksize = 0;
+ return 0;
+ }
+
+ /* valid range? */
+ if (size >= THREAD_MIN_STACKSIZE && size < THREAD_MAX_STACKSIZE) {
+ _pythread_stacksize = size;
+ return 0;
+ }
+ else {
+ char warning[128];
+ snprintf(warning,
+ 128,
+ "thread stack size of %#x bytes not supported on Win32",
+ size);
+ return PyErr_Warn(PyExc_RuntimeWarning, warning);
+ }
+}
+
+#undef THREAD_SET_STACKSIZE
+#define THREAD_SET_STACKSIZE(x) _pythread_nt_set_stacksize(x)