fix panic concurrent parse

concurrent_parse_test.go

@@ -11,7 +11,7 @@ import (
 func TestConcurrentParse(t *testing.T) {
 	var wg sync.WaitGroup
 
-	for i := 0; i < 10; i++ {
+	for i := 0; i < 100; i++ {
 		wg.Add(1)
 		go func() {
 			defer wg.Done()

schema.go

@@ -131,6 +131,17 @@ func (c *SchemaCache) Get(name string) Schema {
 	return nil
 }
 
+// AddAll adds all schemas from the given cache to the current cache.
+func (c *SchemaCache) AddAll(cache *SchemaCache) {
+	if cache == nil {
+		return
+	}
+	cache.cache.Range(func(key, value interface{}) bool {
+		c.cache.Store(key, value)
+		return true
+	})
+}
+
 // Schemas is a slice of Schemas.
 type Schemas []Schema
 

schema_parse.go

@@ -64,16 +64,7 @@ func ParseFiles(paths ...string) (Schema, error) {
 
 // ParseBytes parses a schema byte slice.
 func ParseBytes(schema []byte) (Schema, error) {
-	var internalCache = &SchemaCache{}
-	DefaultSchemaCache.cache.Range(func(key, value any) bool {
-		internalCache.Add(key.(string), value.(Schema))
-		return true
-	})
-	s, err := ParseBytesWithCache(schema, "", internalCache)
-	internalCache.cache.Range(func(key, value any) bool {
-		DefaultSchemaCache.Add(key.(string), value.(Schema))
-		return true
-	})
+	s, err := ParseBytesWithCache(schema, "", DefaultSchemaCache)
 	return s, err
 }
 
@@ -84,11 +75,17 @@ func ParseBytesWithCache(schema []byte, namespace string, cache *SchemaCache) (S
 		json = string(schema)
 	}
 
+	internalCache := &SchemaCache{}
+	internalCache.AddAll(DefaultSchemaCache)
+
 	seen := seenCache{}
-	s, err := parseType(namespace, json, seen, cache)
+	s, err := parseType(namespace, json, seen, internalCache)
 	if err != nil {
 		return nil, err
 	}
+
+	DefaultSchemaCache.AddAll(internalCache)
+
 	return derefSchema(s), nil
 }