Upd nst flag (#182)

* Add platform-specific thread ID retrieval and enforce strict thread checks

* fix of win

* Add strict thread checking mode to ensure thread safety in transactions

* Refactor StrictThreadCheck to strictThreadCheck for naming consistency

---------

Co-authored-by: JkLondon <ilya@mikheev.fun>

Author: JkLondon

mdbx/env.go

@@ -138,6 +138,8 @@ type Env struct {
 	// closeLock is used to allow the Txn finalizer to check if the Env has
 	// been closed, so that it may know if it must abort.
 	closeLock sync.RWMutex
+
+	strictThreadCheck bool
 }
 
 // NewEnv allocates and initializes a new Env.
@@ -164,6 +166,11 @@ func (env *Env) Open(path string, flags uint, mode os.FileMode) error {
 }
 func (env *Env) Label() Label { return env.label }
 
+// SetStrictThreadMode in this mode mdbx panics when tx opening and closing are happening in different threads
+func (env *Env) SetStrictThreadMode(mode bool) {
+	env.strictThreadCheck = mode
+}
+
 var errNotOpen = errors.New("enivornment is not open")
 
 /* TODO: fix error: cannot convert *mf (variable of type _Ctype_HANDLE) to type uintptr

mdbx/txn.go

@@ -90,7 +90,9 @@ func beginTxn(env *Env, parent *Txn, flags uint) (*Txn, error) {
 		readonly: flags&Readonly != 0,
 		env:      env,
 	}
-	txn.tid = threads.CurrentThreadID()
+	if env.strictThreadCheck {
+		txn.tid = threads.CurrentThreadID()
+	}
 
 	var ptxn *C.MDBX_txn
 	if parent != nil {
@@ -304,6 +306,9 @@ func (txn *Txn) Abort() {
 }
 
 func (txn *Txn) strictThreadCheck() {
+	if !txn.env.strictThreadCheck {
+		return
+	}
 	currentThread := threads.CurrentThreadID()
 	if currentThread != txn.tid {
 		msg := fmt.Sprintf("thread mismatch. not allowed current %d, open in %d", currentThread, txn.tid)
@@ -319,7 +324,9 @@ func (txn *Txn) abort() {
 	// Get a read-lock on the environment so we can abort txn if needed.
 	// txn.env **should** terminate all readers otherwise when it closes.
 	txn.env.closeLock.RLock()
-	txn.strictThreadCheck()
+	if txn.env.strictThreadCheck {
+		txn.strictThreadCheck()
+	}
 	if txn.env._env != nil {
 		C.mdbx_txn_abort(txn._txn)
 	}