summaryrefslogtreecommitdiff
path: root/docs/examples/userguide/parallelism/parallel.pyx
diff options
context:
space:
mode:
Diffstat (limited to 'docs/examples/userguide/parallelism/parallel.pyx')
-rw-r--r--docs/examples/userguide/parallelism/parallel.pyx30
1 files changed, 30 insertions, 0 deletions
diff --git a/docs/examples/userguide/parallelism/parallel.pyx b/docs/examples/userguide/parallelism/parallel.pyx
new file mode 100644
index 000000000..2a952d537
--- /dev/null
+++ b/docs/examples/userguide/parallelism/parallel.pyx
@@ -0,0 +1,30 @@
+from cython.parallel import parallel, prange
+from libc.stdlib cimport abort, malloc, free
+
+
+
+cdef void func(int *buf) nogil:
+ pass
+ # ...
+
+cdef Py_ssize_t idx, i, j, n = 100
+cdef int * local_buf
+cdef size_t size = 10
+
+
+
+
+with nogil, parallel():
+ local_buf = <int *> malloc(sizeof(int) * size)
+ if local_buf is NULL:
+ abort()
+
+ # populate our local buffer in a sequential loop
+ for i in range(size):
+ local_buf[i] = i * 2
+
+ # share the work using the thread-local buffer(s)
+ for j in prange(n, schedule='guided'):
+ func(local_buf)
+
+ free(local_buf)