diff options
| author | Alex Gorrod <alexander.gorrod@mongodb.com> | 2017-06-14 19:38:15 +0000 |
|---|---|---|
| committer | Alex Gorrod <alexander.gorrod@mongodb.com> | 2017-06-14 19:38:15 +0000 |
| commit | 47e8c3d1d22018eaaa09f91dfd78addb49e0b49b (patch) | |
| tree | 2d24fbd1e6c03d438d267b737becc318ca6fbadf /examples | |
| parent | 7aaeaaa054d1ac27a95c79984f7ca69ba739caae (diff) | |
| parent | 84429199fd94f8a8201c5aa77432a2557d326902 (diff) | |
Merge branch 'develop' into mongodb-3.6mongodb-3.5.9
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/c/ex_thread.c | 20 |
1 files changed, 6 insertions, 14 deletions
diff --git a/examples/c/ex_thread.c b/examples/c/ex_thread.c index b69b3e9e7e9..ad2ff7f68a0 100644 --- a/examples/c/ex_thread.c +++ b/examples/c/ex_thread.c @@ -34,22 +34,14 @@ #include <stdlib.h> #include <string.h> -#ifndef _WIN32 -#include <pthread.h> -#else -#include "windows_shim.h" -#endif - -#include <wiredtiger.h> +#include "wt_internal.h" static const char *home; -void *scan_thread(void *arg); - #define NUM_THREADS 10 /*! [thread scan] */ -void * +static WT_THREAD_RET scan_thread(void *conn_arg) { WT_CONNECTION *conn; @@ -74,7 +66,7 @@ scan_thread(void *conn_arg) fprintf(stderr, "WT_CURSOR.next: %s\n", session->strerror(session, ret)); - return (NULL); + return (WT_THREAD_RET_VALUE); } /*! [thread scan] */ @@ -85,7 +77,7 @@ main(void) WT_CONNECTION *conn; WT_SESSION *session; WT_CURSOR *cursor; - pthread_t threads[NUM_THREADS]; + wt_thread_t threads[NUM_THREADS]; int i, ret; /* @@ -114,10 +106,10 @@ main(void) ret = session->close(session, NULL); for (i = 0; i < NUM_THREADS; i++) - ret = pthread_create(&threads[i], NULL, scan_thread, conn); + ret = __wt_thread_create(NULL, &threads[i], scan_thread, conn); for (i = 0; i < NUM_THREADS; i++) - ret = pthread_join(threads[i], NULL); + ret = __wt_thread_join(NULL, threads[i]); ret = conn->close(conn, NULL); |
