1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
/*
* Copyright 2017-2021 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/
package kotlinx.serialization.json.internal
import kotlinx.serialization.descriptors.*
import kotlin.native.concurrent.*
private typealias DescriptorData<T> = MutableMap<DescriptorSchemaCache.Key<T>, T>
/**
* A type-safe map for storing custom information (such as format schema), associated with [SerialDescriptor].
*
* This cache uses ConcurrentHashMap on JVM and regular maps on other platforms.
* To be able to work with it from multiple threads in Kotlin/Native, use @[ThreadLocal] in appropriate places.
*/
internal class DescriptorSchemaCache {
private val map: MutableMap<SerialDescriptor, DescriptorData<Any>> = createMapForCache(1)
@Suppress("UNCHECKED_CAST")
public operator fun <T : Any> set(descriptor: SerialDescriptor, key: Key<T>, value: T) {
map.getOrPut(descriptor, { createMapForCache(1) })[key as Key<Any>] = value as Any
}
public fun <T : Any> getOrPut(descriptor: SerialDescriptor, key: Key<T>, defaultValue: () -> T): T {
get(descriptor, key)?.let { return it }
val value = defaultValue()
set(descriptor, key, value)
return value
}
@Suppress("UNCHECKED_CAST")
public operator fun <T : Any> get(descriptor: SerialDescriptor, key: Key<T>): T? {
return map[descriptor]?.get(key as Key<Any>) as? T
}
/**
* A key for associating user data of type [T] with a given [SerialDescriptor].
*/
public class Key<T : Any> {}
}
/**
* Creates a ConcurrentHashMap on JVM and regular HashMap on other platforms.
* To make actual use of cache in Kotlin/Native, mark a top-level object with this map
* as a @[ThreadLocal].
*/
internal expect fun <K, V> createMapForCache(initialCapacity: Int): MutableMap<K, V>
|
