mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-06 04:40:17 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix support concurrency

Browse Source
This commit is contained in:
ylz
2024-06-13 17:42:52 +08:00
parent b431718ee6
commit f9a2a397ad
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/com/actiontech/dble/DbleServer.java
View File

@@ -457,11 +457,13 @@ public final class DbleServer {
}
public NIOProcessor nextFrontProcessor() {
int i = ++nextFrontProcessor;
if (i >= frontProcessors.length) {
i = nextFrontProcessor = 0;
synchronized (this) {
int i = ++nextFrontProcessor;
if (i >= frontProcessors.length) {
i = nextFrontProcessor = 0;
}
return frontProcessors[i];
}
return frontProcessors[i];
}
public NIOProcessor nextBackendProcessor() {