Lock: Add lock mechanism with array of input sigs

internal/runtime/funcs/lockall.go

@@ -0,0 +1,61 @@
+package funcs
+
+import (
+	"context"
+	"errors"
+
+	"github.com/nevalang/neva/internal/runtime"
+)
+
+type lockAll struct{}
+
+func (l lockAll) Create(io runtime.FuncIO, _ runtime.Msg) (func(ctx context.Context), error) {
+	sigIn, ok := io.In["sig"]
+	if !ok {
+		return nil, errors.New("inport 'sig' is required")
+	}
+
+	dataIn, err := io.In.Port("data")
+	if err != nil {
+		return nil, err
+	}
+
+	dataOut, err := io.Out.Port("data")
+	if err != nil {
+		return nil, err
+	}
+
+	return l.Handle(sigIn, dataIn, dataOut), nil
+}
+
+func (lockAll) Handle(
+	sigIn []chan runtime.Msg,
+	dataIn,
+	dataOut chan runtime.Msg,
+) func(ctx context.Context) {
+	return func(ctx context.Context) {
+		var data runtime.Msg
+
+		for {
+			for _, sig := range sigIn {
+				select {
+				case <-ctx.Done():
+					return
+				case <-sig:
+				}
+			}
+
+			select {
+			case <-ctx.Done():
+				return
+			case data = <-dataIn:
+			}
+
+			select {
+			case <-ctx.Done():
+				return
+			case dataOut <- data:
+			}
+		}
+	}
+}

internal/runtime/funcs/registry.go

@@ -9,10 +9,11 @@ import (
 func CreatorRegistry() map[string]runtime.FuncCreator {
 	return map[string]runtime.FuncCreator{
 		// core
-		"new":    new{},
-		"del":    del{},
-		"lock":   lock{},
-		"unwrap": unwrap{},
+		"new":      new{},
+		"del":      del{},
+		"lock":     lock{},
+		"unwrap":   unwrap{},
+		"lock_all": lockAll{},
 
 		// runtime
 		"panic": panicker{},

std/builtin/core.neva

@@ -7,6 +7,9 @@ pub component Del(msg any) ()
 #extern(lock)
 pub component Lock<T>(sig any, data T) (data T)
 
+#extern(lock_all)
+pub component LockAll<T>([sig] any, data T) (data T)
+
 #extern(panic)
 pub component Panic(msg any) ()