Utility
This commit is contained in:
redkale
443
src/main/java/org/redkale/util/AnonymousUnsafe.java
Normal file
443
src/main/java/org/redkale/util/AnonymousUnsafe.java
Normal file
@@ -0,0 +1,443 @@
|
||||
// package org.redkale.util;
|
||||
//
|
||||
// import java.lang.reflect.Field;
|
||||
// import java.nio.ByteBuffer;
|
||||
//
|
||||
// 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);
|
||||
// }
|
||||
//
|
||||
// @Override
|
||||
// public boolean getBoolean(Object o, long offset) {
|
||||
// return unsafe.getBoolean(o, offset);
|
||||
// }
|
||||
//
|
||||
// @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);
|
||||
// }
|
||||
//
|
||||
// @Override
|
||||
// public long getLong(Object o, long offset) {
|
||||
// return unsafe.getLong(o, offset);
|
||||
// }
|
||||
//
|
||||
// @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);
|
||||
// }
|
||||
//
|
||||
// @Override
|
||||
// public long objectFieldOffset(Field f) {
|
||||
// return unsafe.objectFieldOffset(f);
|
||||
// }
|
||||
//
|
||||
// @Override
|
||||
// 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);
|
||||
// }
|
||||
// }
|
||||
191
src/main/java/org/redkale/util/Unsafe.java
Normal file
191
src/main/java/org/redkale/util/Unsafe.java
Normal file
@@ -0,0 +1,191 @@
|
||||
/*
|
||||
* To change this license header, choose License Headers in Project Properties.
|
||||
* To change this template file, choose Tools | Templates
|
||||
* and open the template in the editor.
|
||||
*/
|
||||
package org.redkale.util;
|
||||
|
||||
import java.lang.reflect.Field;
|
||||
|
||||
/**
|
||||
* sun.misc.Unsafe 封装类
|
||||
*
|
||||
* <p>详情见: https://redkale.org
|
||||
*
|
||||
* @author zhangjx
|
||||
* @since 2.5.0
|
||||
*/
|
||||
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 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 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);
|
||||
}
|
||||
File diff suppressed because one or more lines are too long
Reference in New Issue
Block a user