DBot/overdrive_that_matters
DBot/overdrive_that_matters
3
1
Fork 0
Code Issues 63 Pull Requests Packages Releases Wiki Activity

probablyParallelStream

Browse Source
This commit is contained in:
DBotThePony 2022-10-29 11:19:19 +07:00
parent a757fcc9ab
commit 71fc9601b0
Signed by: DBot
GPG Key ID: DCC23B5715498507
1 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/main/kotlin/ru/dbotthepony/mc/otm/matter/MatterManager.kt
View File

@ -25,6 +25,15 @@ import ru.dbotthepony.mc.otm.core.integerDivisionUp
import ru.dbotthepony.mc.otm.core.registryName import ru.dbotthepony.mc.otm.core.registryName
import ru.dbotthepony.mc.otm.core.set import ru.dbotthepony.mc.otm.core.set
import ru.dbotthepony.mc.otm.data.stream import ru.dbotthepony.mc.otm.data.stream
import java.util.stream.Stream
private fun <T> Collection<T>.probablyParallelStream(): Stream<out T> {
if (size >= 400) {
return parallelStream()
}
return stream()
}
object MatterManager : SimpleJsonResourceReloadListener(GsonBuilder().setPrettyPrinting().disableHtmlEscaping().create(), "otm_matter") { object MatterManager : SimpleJsonResourceReloadListener(GsonBuilder().setPrettyPrinting().disableHtmlEscaping().create(), "otm_matter") {
const val DIRECTORY = "otm_matter" const val DIRECTORY = "otm_matter"
@ -222,7 +231,7 @@ object MatterManager : SimpleJsonResourceReloadListener(GsonBuilder().setPrettyP
if (key != null) { if (key != null) {
if (replaceIfExists) { if (replaceIfExists) {
// search & replace in parallel, if possible // search & replace in parallel, if possible
val replaced = registry.parallelStream().anyMatch { val replaced = registry.probablyParallelStream().anyMatch {
if (it is MutableKeyEntry && it.key == key) { if (it is MutableKeyEntry && it.key == key) {
if (!comparePriority || it.priority < priority!!) { if (!comparePriority || it.priority < priority!!) {
it.matter = matter it.matter = matter
@ -242,7 +251,7 @@ object MatterManager : SimpleJsonResourceReloadListener(GsonBuilder().setPrettyP
registry.add(MutableKeyEntry(key, mutableListOf(modifier), matter, complexity, priority ?: 0)) registry.add(MutableKeyEntry(key, mutableListOf(modifier), matter, complexity, priority ?: 0))
} }
} else { } else {
if (registry.parallelStream().anyMatch { it is MutableKeyEntry && it.key == key }) { if (registry.probablyParallelStream().anyMatch { it is MutableKeyEntry && it.key == key }) {
fail { "Value with key $key already exists" } fail { "Value with key $key already exists" }
return return
} }
@ -252,7 +261,7 @@ object MatterManager : SimpleJsonResourceReloadListener(GsonBuilder().setPrettyP
} else { } else {
if (replaceIfExists) { if (replaceIfExists) {
// search & replace in parallel, if possible // search & replace in parallel, if possible
val replaced = registry.parallelStream().anyMatch { val replaced = registry.probablyParallelStream().anyMatch {
if (it is MutableTagEntry && it.tag == tag) { if (it is MutableTagEntry && it.tag == tag) {
if (!comparePriority || it.priority < priority!!) { if (!comparePriority || it.priority < priority!!) {
it.matter = matter it.matter = matter
@ -272,7 +281,7 @@ object MatterManager : SimpleJsonResourceReloadListener(GsonBuilder().setPrettyP
registry.add(MutableTagEntry(tag!!, mutableListOf(modifier), matter, complexity, priority ?: 0)) registry.add(MutableTagEntry(tag!!, mutableListOf(modifier), matter, complexity, priority ?: 0))
} }
} else { } else {
if (registry.parallelStream().anyMatch { it is MutableTagEntry && it.tag == tag }) { if (registry.probablyParallelStream().anyMatch { it is MutableTagEntry && it.tag == tag }) {
fail { "Value with tag $tag already exists" } fail { "Value with tag $tag already exists" }
return return
} }