diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-16 19:25:22 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-16 19:25:22 +0000 |
commit | f6ad4dcef54c5ce997a4bad5a6d86de229015700 (patch) | |
tree | 7cfa4e31ace5c2bd95c72b154d15af494b2bcbef /src/cmd/cgo/internal/test/cthread_windows.c | |
parent | Initial commit. (diff) | |
download | golang-1.22-f6ad4dcef54c5ce997a4bad5a6d86de229015700.tar.xz golang-1.22-f6ad4dcef54c5ce997a4bad5a6d86de229015700.zip |
Adding upstream version 1.22.1.upstream/1.22.1
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'src/cmd/cgo/internal/test/cthread_windows.c')
-rw-r--r-- | src/cmd/cgo/internal/test/cthread_windows.c | 59 |
1 files changed, 59 insertions, 0 deletions
diff --git a/src/cmd/cgo/internal/test/cthread_windows.c b/src/cmd/cgo/internal/test/cthread_windows.c new file mode 100644 index 0000000..4e52209 --- /dev/null +++ b/src/cmd/cgo/internal/test/cthread_windows.c @@ -0,0 +1,59 @@ +// Copyright 2013 The Go Authors. All rights reserved. +// Use of this source code is governed by a BSD-style +// license that can be found in the LICENSE file. + +#define WIN32_LEAN_AND_MEAN +#include <windows.h> +#include <process.h> +#include "_cgo_export.h" + +__stdcall +static unsigned int +addThread(void *p) +{ + int i, max; + + max = *(int*)p; + for(i=0; i<max; i++) + Add(i); + return 0; +} + +void +doAdd(int max, int nthread) +{ + enum { MaxThread = 20 }; + int i; + uintptr_t thread_id[MaxThread]; + + if(nthread > MaxThread) + nthread = MaxThread; + for(i=0; i<nthread; i++) + thread_id[i] = _beginthreadex(0, 0, addThread, &max, 0, 0); + for(i=0; i<nthread; i++) { + WaitForSingleObject((HANDLE)thread_id[i], INFINITE); + CloseHandle((HANDLE)thread_id[i]); + } +} + +__stdcall +static unsigned int +goDummyCallbackThread(void* p) +{ + int i, max; + + max = *(int*)p; + for(i=0; i<max; i++) + goDummy(); + return 0; +} + +int +callGoInCThread(int max) +{ + uintptr_t thread_id; + thread_id = _beginthreadex(0, 0, goDummyCallbackThread, &max, 0, 0); + WaitForSingleObject((HANDLE)thread_id, INFINITE); + CloseHandle((HANDLE)thread_id); + return max; +} |