Gecko [ 167.86.127.34 ]

Name	Size	Permission
windows	[ DIR ]	drwxr-xr-x
aprof.go	947 B	-rw-r--r--
bigstack_windows.c	1.2 KB	-rw-r--r--
bigstack_windows.go	578 B	-rw-r--r--
callback.go	1.38 KB	-rw-r--r--
catchpanic.go	963 B	-rw-r--r--
cgo.go	1.82 KB	-rw-r--r--
crash.go	743 B	-rw-r--r--
deadlock.go	509 B	-rw-r--r--
dll_windows.go	459 B	-rw-r--r--
dropm.go	1.02 KB	-rw-r--r--
dropm_stub.go	333 B	-rw-r--r--
exec.go	2.06 KB	-rw-r--r--
lockosthread.c	301 B	-rw-r--r--
lockosthread.go	2.56 KB	-rw-r--r--
main.go	651 B	-rw-r--r--
numgoroutine.go	1.89 KB	-rw-r--r--
pprof.go	1.88 KB	-rw-r--r--
raceprof.go	1.68 KB	-rw-r--r--
racesig.go	1.89 KB	-rw-r--r--
sigpanic.go	484 B	-rw-r--r--
sigstack.go	2.06 KB	-rw-r--r--
stack_windows.go	987 B	-rw-r--r--
threadpanic.go	410 B	-rw-r--r--
threadpanic_unix.c	435 B	-rw-r--r--
threadpanic_windows.c	435 B	-rw-r--r--
threadpprof.go	2.36 KB	-rw-r--r--
threadprof.go	2.11 KB	-rw-r--r--
traceback.go	1.42 KB	-rw-r--r--
tracebackctxt.go	2.17 KB	-rw-r--r--
tracebackctxt_c.c	2.02 KB	-rw-r--r--

Code Editor : lockosthread.go

// Copyright 2017 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.

// +build !plan9,!windows

package main

import (
	"os"
	"runtime"
	"sync/atomic"
	"time"
	"unsafe"
)

/*
#include <pthread.h>
#include <stdint.h>

extern uint32_t threadExited;

void setExited(void *x);
*/
import "C"

var mainThread C.pthread_t

func init() {
	registerInit("LockOSThreadMain", func() {
		// init is guaranteed to run on the main thread.
		mainThread = C.pthread_self()
	})
	register("LockOSThreadMain", LockOSThreadMain)

registerInit("LockOSThreadAlt", func() {
		// Lock the OS thread now so main runs on the main thread.
		runtime.LockOSThread()
	})
	register("LockOSThreadAlt", LockOSThreadAlt)
}

func LockOSThreadMain() {
	// This requires GOMAXPROCS=1 from the beginning to reliably
	// start a goroutine on the main thread.
	if runtime.GOMAXPROCS(-1) != 1 {
		println("requires GOMAXPROCS=1")
		os.Exit(1)
	}

ready := make(chan bool, 1)
	go func() {
		// Because GOMAXPROCS=1, this *should* be on the main
		// thread. Stay there.
		runtime.LockOSThread()
		self := C.pthread_self()
		if C.pthread_equal(mainThread, self) == 0 {
			println("failed to start goroutine on main thread")
			os.Exit(1)
		}
		// Exit with the thread locked, which should exit the
		// main thread.
		ready <- true
	}()
	<-ready
	time.Sleep(1 * time.Millisecond)
	// Check that this goroutine is still running on a different
	// thread.
	self := C.pthread_self()
	if C.pthread_equal(mainThread, self) != 0 {
		println("goroutine migrated to locked thread")
		os.Exit(1)
	}
	println("OK")
}

func LockOSThreadAlt() {
	// This is running locked to the main OS thread.

var subThread C.pthread_t
	ready := make(chan bool, 1)
	C.threadExited = 0
	go func() {
		// This goroutine must be running on a new thread.
		runtime.LockOSThread()
		subThread = C.pthread_self()
		// Register a pthread destructor so we can tell this
		// thread has exited.
		var key C.pthread_key_t
		C.pthread_key_create(&key, (*[0]byte)(unsafe.Pointer(C.setExited)))
		C.pthread_setspecific(key, unsafe.Pointer(new(int)))
		ready <- true
		// Exit with the thread locked.
	}()
	<-ready
	for i := 0; i < 100; i++ {
		time.Sleep(1 * time.Millisecond)
		// Check that this goroutine is running on a different thread.
		self := C.pthread_self()
		if C.pthread_equal(subThread, self) != 0 {
			println("locked thread reused")
			os.Exit(1)
		}
		if atomic.LoadUint32((*uint32)(&C.threadExited)) != 0 {
			println("OK")
			return
		}
	}
	println("sub thread still running")
	os.Exit(1)
}

${this.title}

Code Editor : lockosthread.go