lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Unsafe优化

Browse Source
This commit is contained in:
redkale
2024-10-07 09:38:03 +08:00
parent d6a90f23a5
commit 1db55185d7
3 changed files with 34 additions and 550 deletions
Download Patch File Download Diff File Expand all files Collapse all files

405
src/main/java/org/redkale/util/AnonymousUnsafe.java
View File

@@ -1,34 +1,22 @@
// package org.redkale.util;
//package org.redkale.util;
//
// import java.lang.reflect.Field;
// import java.nio.ByteBuffer;
//import java.lang.reflect.Field;
//import java.util.Objects;
//
// public class AnonymousUnsafe implements Unsafe {
//public class AnonymousUnsafe implements Unsafe {
//
// private final sun.misc.Unsafe unsafe;
//
// public AnonymousUnsafe(Object obj) {
// this.unsafe = (sun.misc.Unsafe) obj;
// }
//
// @Override
// public int getInt(Object o, long offset) {
// return unsafe.getInt(o, offset);
// }
//
// @Override
// public void putInt(Object o, long offset, int x) {
// unsafe.putInt(o, offset, x);
// }
//
// @Override
// public Object getObject(Object o, long offset) {
// return unsafe.getObject(o, offset);
// }
//
// @Override
// public void putObject(Object o, long offset, Object x) {
// unsafe.putObject(o, offset, x);
// public AnonymousUnsafe() {
// sun.misc.Unsafe unsafe0 = null;
// try {
// Field field = sun.misc.Unsafe.class.getDeclaredField("theUnsafe");
// field.setAccessible(true);
// unsafe0 = (sun.misc.Unsafe) field.get(null);
// } catch (Throwable e) {
// throw new RedkaleException("init unsafe error", e);
// }
// this.unsafe = Objects.requireNonNull(unsafe0);
// }
//
// @Override
@@ -37,38 +25,23 @@
// }
//
// @Override
// public void putBoolean(Object o, long offset, boolean x) {
// unsafe.putBoolean(o, offset, x);
// }
//
// @Override
// public byte getByte(Object o, long offset) {
// return unsafe.getByte(o, offset);
// }
//
// @Override
// public void putByte(Object o, long offset, byte x) {
// unsafe.putByte(o, offset, x);
// }
//
// @Override
// public short getShort(Object o, long offset) {
// return unsafe.getShort(o, offset);
// }
//
// @Override
// public void putShort(Object o, long offset, short x) {
// unsafe.putShort(o, offset, x);
// }
//
// @Override
// public char getChar(Object o, long offset) {
// return unsafe.getChar(o, offset);
// }
//
// @Override
// public void putChar(Object o, long offset, char x) {
// unsafe.putChar(o, offset, x);
// public int getInt(Object o, long offset) {
// return unsafe.getInt(o, offset);
// }
//
// @Override
@@ -77,143 +50,18 @@
// }
//
// @Override
// public void putLong(Object o, long offset, long x) {
// unsafe.putLong(o, offset, x);
// }
//
// @Override
// public float getFloat(Object o, long offset) {
// return unsafe.getFloat(o, offset);
// }
//
// @Override
// public void putFloat(Object o, long offset, float x) {
// unsafe.putFloat(o, offset, x);
// }
//
// @Override
// public double getDouble(Object o, long offset) {
// return unsafe.getDouble(o, offset);
// }
//
// @Override
// public void putDouble(Object o, long offset, double x) {
// unsafe.putDouble(o, offset, x);
// }
//
// @Override
// public byte getByte(long address) {
// return unsafe.getByte(address);
// }
//
// @Override
// public void putByte(long address, byte x) {
// unsafe.putByte(address, x);
// }
//
// @Override
// public short getShort(long address) {
// return unsafe.getShort(address);
// }
//
// @Override
// public void putShort(long address, short x) {
// unsafe.putShort(address, x);
// }
//
// @Override
// public char getChar(long address) {
// return unsafe.getChar(address);
// }
//
// @Override
// public void putChar(long address, char x) {
// unsafe.putChar(address, x);
// }
//
// @Override
// public int getInt(long address) {
// return unsafe.getInt(address);
// }
//
// @Override
// public void putInt(long address, int x) {
// unsafe.putInt(address, x);
// }
//
// @Override
// public long getLong(long address) {
// return unsafe.getLong(address);
// }
//
// @Override
// public void putLong(long address, long x) {
// unsafe.putLong(address, x);
// }
//
// @Override
// public float getFloat(long address) {
// return unsafe.getFloat(address);
// }
//
// @Override
// public void putFloat(long address, float x) {
// unsafe.putFloat(address, x);
// }
//
// @Override
// public double getDouble(long address) {
// return unsafe.getDouble(address);
// }
//
// @Override
// public void putDouble(long address, double x) {
// unsafe.putDouble(address, x);
// }
//
// @Override
// public long getAddress(long address) {
// return unsafe.getAddress(address);
// }
//
// @Override
// public void putAddress(long address, long x) {
// unsafe.putAddress(address, x);
// }
//
// @Override
// public long allocateMemory(long bytes) {
// return unsafe.allocateMemory(bytes);
// }
//
// @Override
// public long reallocateMemory(long address, long bytes) {
// return unsafe.reallocateMemory(address, bytes);
// }
//
// @Override
// public void setMemory(Object o, long offset, long bytes, byte value) {
// unsafe.setMemory(o, offset, bytes, value);
// }
//
// @Override
// public void setMemory(long address, long bytes, byte value) {
// unsafe.setMemory(address, bytes, value);
// }
//
// @Override
// public void copyMemory(Object srcBase, long srcOffset, Object destBase, long destOffset, long bytes) {
// unsafe.copyMemory(srcBase, srcOffset, destBase, destOffset, bytes);
// }
//
// @Override
// public void copyMemory(long srcAddress, long destAddress, long bytes) {
// unsafe.copyMemory(srcAddress, destAddress, bytes);
// }
//
// @Override
// public void freeMemory(long address) {
// unsafe.freeMemory(address);
// public Object getObject(Object o, long offset) {
// return unsafe.getObject(o, offset);
// }
//
// @Override
@@ -225,219 +73,4 @@
// public long staticFieldOffset(Field f) {
// return unsafe.staticFieldOffset(f);
// }
//
// @Override
// public Object staticFieldBase(Field f) {
// return unsafe.staticFieldBase(f);
// }
//
// @Override
// public int arrayBaseOffset(Class<?> arrayClass) {
// return unsafe.arrayBaseOffset(arrayClass);
// }
//
// @Override
// public int arrayIndexScale(Class<?> arrayClass) {
// return unsafe.arrayIndexScale(arrayClass);
// }
//
// @Override
// public int addressSize() {
// return unsafe.addressSize();
// }
//
// @Override
// public int pageSize() {
// return unsafe.pageSize();
// }
//
// @Override
// public Object allocateInstance(Class<?> cls) throws InstantiationException {
// return unsafe.allocateInstance(cls);
// }
//
// @Override
// public void throwException(Throwable ee) {
// unsafe.throwException(ee);
// }
//
// @Override
// public boolean compareAndSwapObject(Object o, long offset, Object expected, Object x) {
// return unsafe.compareAndSwapObject(o, offset, expected, x);
// }
//
// @Override
// public boolean compareAndSwapInt(Object o, long offset, int expected, int x) {
// return unsafe.compareAndSwapInt(o, offset, expected, x);
// }
//
// @Override
// public boolean compareAndSwapLong(Object o, long offset, long expected, long x) {
// return unsafe.compareAndSwapLong(o, offset, expected, x);
// }
//
// @Override
// public Object getObjectVolatile(Object o, long offset) {
// return unsafe.getObjectVolatile(o, offset);
// }
//
// @Override
// public void putObjectVolatile(Object o, long offset, Object x) {
// unsafe.putObjectVolatile(o, offset, x);
// }
//
// @Override
// public int getIntVolatile(Object o, long offset) {
// return unsafe.getIntVolatile(o, offset);
// }
//
// @Override
// public void putIntVolatile(Object o, long offset, int x) {
// unsafe.putIntVolatile(o, offset, x);
// }
//
// @Override
// public boolean getBooleanVolatile(Object o, long offset) {
// return unsafe.getBooleanVolatile(o, offset);
// }
//
// @Override
// public void putBooleanVolatile(Object o, long offset, boolean x) {
// unsafe.putBooleanVolatile(o, offset, x);
// }
//
// @Override
// public byte getByteVolatile(Object o, long offset) {
// return unsafe.getByteVolatile(o, offset);
// }
//
// @Override
// public void putByteVolatile(Object o, long offset, byte x) {
// unsafe.putByteVolatile(o, offset, x);
// }
//
// @Override
// public short getShortVolatile(Object o, long offset) {
// return unsafe.getShortVolatile(o, offset);
// }
//
// @Override
// public void putShortVolatile(Object o, long offset, short x) {
// unsafe.putShortVolatile(o, offset, x);
// }
//
// @Override
// public char getCharVolatile(Object o, long offset) {
// return unsafe.getCharVolatile(o, offset);
// }
//
// @Override
// public void putCharVolatile(Object o, long offset, char x) {
// unsafe.putCharVolatile(o, offset, x);
// }
//
// @Override
// public long getLongVolatile(Object o, long offset) {
// return unsafe.getLongVolatile(o, offset);
// }
//
// @Override
// public void putLongVolatile(Object o, long offset, long x) {
// unsafe.putLongVolatile(o, offset, x);
// }
//
// @Override
// public float getFloatVolatile(Object o, long offset) {
// return unsafe.getFloatVolatile(o, offset);
// }
//
// @Override
// public void putFloatVolatile(Object o, long offset, float x) {
// unsafe.putFloatVolatile(o, offset, x);
// }
//
// @Override
// public double getDoubleVolatile(Object o, long offset) {
// return unsafe.getDoubleVolatile(o, offset);
// }
//
// @Override
// public void putDoubleVolatile(Object o, long offset, double x) {
// unsafe.putDoubleVolatile(o, offset, x);
// }
//
// @Override
// public void putOrderedObject(Object o, long offset, Object x) {
// unsafe.putOrderedObject(o, offset, x);
// }
//
// @Override
// public void putOrderedInt(Object o, long offset, int x) {
// unsafe.putOrderedInt(o, offset, x);
// }
//
// @Override
// public void putOrderedLong(Object o, long offset, long x) {
// unsafe.putOrderedLong(o, offset, x);
// }
//
// @Override
// public void unpark(Object thread) {
// unsafe.unpark(thread);
// }
//
// @Override
// public void park(boolean isAbsolute, long time) {
// unsafe.park(isAbsolute, time);
// }
//
// @Override
// public int getLoadAverage(double[] loadavg, int nelems) {
// return unsafe.getLoadAverage(loadavg, nelems);
// }
//
// @Override
// public int getAndAddInt(Object o, long offset, int delta) {
// return unsafe.getAndAddInt(o, offset, delta);
// }
//
// @Override
// public long getAndAddLong(Object o, long offset, long delta) {
// return unsafe.getAndAddLong(o, offset, delta);
// }
//
// @Override
// public int getAndSetInt(Object o, long offset, int newValue) {
// return unsafe.getAndSetInt(o, offset, newValue);
// }
//
// @Override
// public long getAndSetLong(Object o, long offset, long newValue) {
// return unsafe.getAndSetLong(o, offset, newValue);
// }
//
// @Override
// public Object getAndSetObject(Object o, long offset, Object newValue) {
// return unsafe.getAndSetObject(o, offset, newValue);
// }
//
// @Override
// public void loadFence() {
// unsafe.loadFence();
// }
//
// @Override
// public void storeFence() {
// unsafe.storeFence();
// }
//
// @Override
// public void fullFence() {
// unsafe.fullFence();
// }
//
// @Override
// public void invokeCleaner(ByteBuffer directBuffer) {
// unsafe.invokeCleaner(directBuffer);
// }
// }
//}

154
src/main/java/org/redkale/util/Unsafe.java
View File

@@ -17,175 +17,25 @@ import java.lang.reflect.Field;
*/
public interface Unsafe {
public int getInt(Object o, long offset);
public void putInt(Object o, long offset, int x);
public Object getObject(Object o, long offset);
public void putObject(Object o, long offset, Object x);
public boolean getBoolean(Object o, long offset);
public void putBoolean(Object o, long offset, boolean x);
public byte getByte(Object o, long offset);
public void putByte(Object o, long offset, byte x);
public short getShort(Object o, long offset);
public void putShort(Object o, long offset, short x);
public char getChar(Object o, long offset);
public void putChar(Object o, long offset, char x);
public int getInt(Object o, long offset);
public long getLong(Object o, long offset);
public void putLong(Object o, long offset, long x);
public float getFloat(Object o, long offset);
public void putFloat(Object o, long offset, float x);
public double getDouble(Object o, long offset);
public void putDouble(Object o, long offset, double x);
public byte getByte(long address);
public void putByte(long address, byte x);
public short getShort(long address);
public void putShort(long address, short x);
public char getChar(long address);
public void putChar(long address, char x);
public int getInt(long address);
public void putInt(long address, int x);
public long getLong(long address);
public void putLong(long address, long x);
public float getFloat(long address);
public void putFloat(long address, float x);
public double getDouble(long address);
public void putDouble(long address, double x);
public long getAddress(long address);
public void putAddress(long address, long x);
public long allocateMemory(long bytes);
public long reallocateMemory(long address, long bytes);
public void setMemory(Object o, long offset, long bytes, byte value);
public void setMemory(long address, long bytes, byte value);
public void copyMemory(Object srcBase, long srcOffset, Object destBase, long destOffset, long bytes);
public void copyMemory(long srcAddress, long destAddress, long bytes);
public void freeMemory(long address);
public Object getObject(Object o, long offset);
public long objectFieldOffset(Field f);
public long staticFieldOffset(Field f);
public Object staticFieldBase(Field f);
public int arrayBaseOffset(Class<?> arrayClass);
public int arrayIndexScale(Class<?> arrayClass);
public int addressSize();
public int pageSize();
public Object allocateInstance(Class<?> cls) throws InstantiationException;
public void throwException(Throwable ee);
public boolean compareAndSwapObject(Object o, long offset, Object expected, Object x);
public boolean compareAndSwapInt(Object o, long offset, int expected, int x);
public boolean compareAndSwapLong(Object o, long offset, long expected, long x);
public Object getObjectVolatile(Object o, long offset);
public void putObjectVolatile(Object o, long offset, Object x);
public int getIntVolatile(Object o, long offset);
public void putIntVolatile(Object o, long offset, int x);
public boolean getBooleanVolatile(Object o, long offset);
public void putBooleanVolatile(Object o, long offset, boolean x);
public byte getByteVolatile(Object o, long offset);
public void putByteVolatile(Object o, long offset, byte x);
public short getShortVolatile(Object o, long offset);
public void putShortVolatile(Object o, long offset, short x);
public char getCharVolatile(Object o, long offset);
public void putCharVolatile(Object o, long offset, char x);
public long getLongVolatile(Object o, long offset);
public void putLongVolatile(Object o, long offset, long x);
public float getFloatVolatile(Object o, long offset);
public void putFloatVolatile(Object o, long offset, float x);
public double getDoubleVolatile(Object o, long offset);
public void putDoubleVolatile(Object o, long offset, double x);
public void putOrderedObject(Object o, long offset, Object x);
public void putOrderedInt(Object o, long offset, int x);
public void putOrderedLong(Object o, long offset, long x);
public void unpark(Object thread);
public void park(boolean isAbsolute, long time);
public int getLoadAverage(double[] loadavg, int nelems);
public int getAndAddInt(Object o, long offset, int delta);
public long getAndAddLong(Object o, long offset, long delta);
public int getAndSetInt(Object o, long offset, int newValue);
public long getAndSetLong(Object o, long offset, long newValue);
public Object getAndSetObject(Object o, long offset, Object newValue);
public void loadFence();
public void storeFence();
public void fullFence();
public void invokeCleaner(java.nio.ByteBuffer directBuffer);
}

25
src/main/java/org/redkale/util/Utility.java
View File

File diff suppressed because one or more lines are too long