Skip to content

Commit 9495672

Browse files
committed
finish re-working on array/concurrent array APIs
1 parent f222f43 commit 9495672

22 files changed

Lines changed: 1339 additions & 604 deletions

rlib-common/src/main/java/com/ss/rlib/common/concurrent/deadlock/DeadLockDetector.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,7 @@ public void run() {
9292
continue;
9393
}
9494

95-
listeners.runInReadLock(info, (list, inf) -> list.forEach(inf, DeadLockListener::onDetected));
95+
listeners.runInReadLock(info, (list, inf) -> list.forEachR(inf, DeadLockListener::onDetected));
9696

9797
LOGGER.warning("DeadLock detected! : " + info);
9898
}
Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
package com.ss.rlib.common.function;
2+
3+
import org.jetbrains.annotations.Nullable;
4+
5+
/**
6+
* @author JavaSaBr
7+
*/
8+
@FunctionalInterface
9+
public interface FloatBiObjectConsumer<S, T> {
10+
11+
void accept(float first, @Nullable S second, @Nullable T third);
12+
}
Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
package com.ss.rlib.common.function;
2+
3+
import org.jetbrains.annotations.NotNull;
4+
5+
/**
6+
* @author JavaSaBr
7+
*/
8+
@FunctionalInterface
9+
public interface NotNullFloatBiObjectConsumer<S, T> extends FloatBiObjectConsumer<S, T> {
10+
11+
@Override
12+
void accept(float first, @NotNull S second, @NotNull T third);
13+
}
Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
package com.ss.rlib.common.function;
2+
3+
import org.jetbrains.annotations.NotNull;
4+
5+
/**
6+
* @author JavaSaBr
7+
*/
8+
@FunctionalInterface
9+
public interface NotNullIntObjectPredicate<T> extends IntObjectPredicate<T> {
10+
11+
boolean test(int first, @NotNull T second);
12+
}
Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
package com.ss.rlib.common.function;
2+
3+
import org.jetbrains.annotations.NotNull;
4+
5+
/**
6+
* @author JavaSaBr
7+
*/
8+
@FunctionalInterface
9+
public interface NotNullLongBiObjectConsumer<S, T> extends LongBiObjectConsumer<S, T> {
10+
11+
@Override
12+
void accept(long first, @NotNull S second, @NotNull T third);
13+
}
Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
package com.ss.rlib.common.function;
2+
3+
import org.jetbrains.annotations.NotNull;
4+
5+
/**
6+
* @author JavaSaBr
7+
*/
8+
@FunctionalInterface
9+
public interface NotNullLongObjectPredicate<T> extends LongObjectPredicate<T> {
10+
11+
boolean test(long first, @NotNull T second);
12+
}
Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
package com.ss.rlib.common.function;
2+
3+
import org.jetbrains.annotations.NotNull;
4+
5+
@FunctionalInterface
6+
public interface NotNullObjectLongPredicate<T> extends ObjectLongPredicate<T> {
7+
8+
@Override
9+
boolean test(@NotNull T first, long second);
10+
}
Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
package com.ss.rlib.common.function;
2+
3+
import org.jetbrains.annotations.NotNull;
4+
5+
/**
6+
* @author JavaSaBr
7+
*/
8+
@FunctionalInterface
9+
public interface NotNullTripleConsumer<F, S, T> extends TripleConsumer<F, S, T> {
10+
11+
@Override
12+
void accept(@NotNull F first, @NotNull S second, @NotNull T third);
13+
}
Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
package com.ss.rlib.common.function;
2+
3+
import org.jetbrains.annotations.NotNull;
4+
5+
/**
6+
* @author JavaSaBr
7+
*/
8+
@FunctionalInterface
9+
public interface NotNullTriplePredicate<F, S, T> extends TriplePredicate<F, S, T> {
10+
11+
boolean test(@NotNull F first, @NotNull S second, @NotNull T third);
12+
}

0 commit comments

Comments
 (0)