* @author sebastien jourdain - sebastien.jourdain@kitware.com
*/
public class vtkJavaMemoryManagerImpl implements vtkJavaMemoryManager {
- private vtkJavaGarbageCollector garbageCollector;
- private ReentrantLock lock;
- private vtkReferenceInformation lastGcResult;
- private HashMap<Long, WeakReference<vtkObjectBase>> objectMap;
- private HashMap<Long, String> objectMapClassName;
-
- public vtkJavaMemoryManagerImpl() {
- this.lock = new ReentrantLock();
- this.objectMap = new HashMap<Long, WeakReference<vtkObjectBase>>();
- this.objectMapClassName = new HashMap<Long, String>();
- this.garbageCollector = new vtkJavaGarbageCollector();
+ private vtkJavaGarbageCollector garbageCollector;
+ private ReentrantLock lock;
+ private vtkReferenceInformation lastGcResult;
+ private HashMap<Long, WeakReference<vtkObjectBase>> objectMap;
+ private HashMap<Long, String> objectMapClassName;
+
+ public vtkJavaMemoryManagerImpl() {
+ this.lock = new ReentrantLock();
+ this.objectMap = new HashMap<Long, WeakReference<vtkObjectBase>>();
+ this.objectMapClassName = new HashMap<Long, String>();
+ this.garbageCollector = new vtkJavaGarbageCollector();
+ }
+
+ // Thread safe
+ public vtkObjectBase getJavaObject(Long vtkId) {
+ // Check pre-condition
+ if (vtkId == null || vtkId.longValue() == 0) {
+ throw new RuntimeException("Invalid ID, can not be null or equal to 0.");
}
- // Thread safe
- public vtkObjectBase getJavaObject(Long vtkId) {
- // Check pre-condition
- if (vtkId == null || vtkId.longValue() == 0) {
- throw new RuntimeException("Invalid ID, can not be null or equal to 0.");
+ // Check inside the map if the object is already there
+ WeakReference<vtkObjectBase> value = objectMap.get(vtkId);
+ vtkObjectBase resultObject = (value == null) ? null : value.get();
+
+ // If not, we have to do something
+ if (value == null || resultObject == null) {
+ try {
+ // Make sure no concurrency could happen inside that
+ this.lock.lock();
+
+ // Now that we have the lock make sure someone else didn't
+ // create the object in between, if so just return the created
+ // instance
+ value = objectMap.get(vtkId);
+ resultObject = (value == null) ? null : value.get();
+ if (resultObject != null) {
+ return resultObject;
}
- // Check inside the map if the object is already there
- WeakReference<vtkObjectBase> value = objectMap.get(vtkId);
- vtkObjectBase resultObject = (value == null) ? null : value.get();
-
- // If not, we have to do something
- if (value == null || resultObject == null) {
- try {
- // Make sure no concurrency could happen inside that
- this.lock.lock();
-
- // Now that we have the lock make sure someone else didn't
- // create the object in between, if so just return the created
- // instance
- value = objectMap.get(vtkId);
- resultObject = (value == null) ? null : value.get();
- if (resultObject != null) {
- return resultObject;
- }
-
- // We need to do the work of the gc
- if (value != null && resultObject == null) {
- this.unRegisterJavaObject(vtkId);
- }
-
- // No-one did create it, so let's do it
- if (resultObject == null) {
- try {
- String className = vtkObjectBase.VTKGetClassNameFromReference(vtkId.longValue());
- Class c = Class.forName("vtk." + className);
- Constructor cons = c.getConstructor(new Class[] { long.class });
- resultObject = (vtkObjectBase) cons.newInstance(new Object[] { vtkId });
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- } finally {
- this.lock.unlock();
- }
+ // We need to do the work of the gc
+ if (value != null && resultObject == null) {
+ this.unRegisterJavaObject(vtkId);
}
- return resultObject;
- }
- // Thread safe
- public void registerJavaObject(Long id, vtkObjectBase obj) {
- try {
- this.lock.lock();
- this.objectMap.put(id, new WeakReference<vtkObjectBase>(obj));
- this.objectMapClassName.put(id, obj.GetClassName());
- } finally {
- this.lock.unlock();
+ // No-one did create it, so let's do it
+ if (resultObject == null) {
+ try {
+ String className = vtkObjectBase.VTKGetClassNameFromReference(vtkId.longValue());
+ Class<?> c = Class.forName("vtk." + className);
+ Constructor<?> cons = c.getConstructor(new Class<?>[] { long.class });
+ resultObject = (vtkObjectBase) cons.newInstance(new Object[] { vtkId });
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
}
+ } finally {
+ this.lock.unlock();
+ }
}
-
- // Thread safe
- public void unRegisterJavaObject(Long id) {
- try {
- this.lock.lock();
- this.objectMapClassName.remove(id);
- WeakReference<vtkObjectBase> value = this.objectMap.remove(id);
-
- // Prevent double deletion...
- if (value != null) {
- vtkObjectBase.VTKDeleteReference(id.longValue());
- } else {
- throw new RuntimeException("You try to delete a vtkObject that is not referenced in the Java object Map. You may have call Delete() twice.");
- }
- } finally {
- this.lock.unlock();
- }
+ return resultObject;
+ }
+
+ // Thread safe
+ public void registerJavaObject(Long id, vtkObjectBase obj) {
+ try {
+ this.lock.lock();
+ this.objectMap.put(id, new WeakReference<vtkObjectBase>(obj));
+ this.objectMapClassName.put(id, obj.GetClassName());
+ } finally {
+ this.lock.unlock();
}
-
- // Thread safe
- public vtkReferenceInformation gc(boolean debug) {
- System.gc();
- try {
- this.lock.lock();
- final vtkReferenceInformation infos = new vtkReferenceInformation(debug);
- for (Long id : new TreeSet<Long>(this.objectMap.keySet())) {
- vtkObjectBase obj = this.objectMap.get(id).get();
- if (obj == null) {
- infos.addFreeObject(this.objectMapClassName.get(id));
- this.unRegisterJavaObject(id);
- } else {
- infos.addKeptObject(this.objectMapClassName.get(id));
- }
- }
-
- this.lastGcResult = infos;
- return infos;
- } finally {
- this.lock.unlock();
- }
+ }
+
+ // Thread safe
+ public void unRegisterJavaObject(Long id) {
+ try {
+ this.lock.lock();
+ this.objectMapClassName.remove(id);
+ WeakReference<vtkObjectBase> value = this.objectMap.remove(id);
+
+ // Prevent double deletion...
+ if (value != null) {
+ vtkObjectBase.VTKDeleteReference(id.longValue());
+ } else {
+ throw new RuntimeException("You try to delete a vtkObject that is not referenced in the Java object Map. You may have call Delete() twice.");
+ }
+ } finally {
+ this.lock.unlock();
}
+ }
+
+ // Thread safe
+ public vtkReferenceInformation gc(boolean debug) {
+ System.gc();
+ try {
+ this.lock.lock();
+ final vtkReferenceInformation infos = new vtkReferenceInformation(debug);
+ for (Long id : new TreeSet<Long>(this.objectMap.keySet())) {
+ vtkObjectBase obj = this.objectMap.get(id).get();
+ if (obj == null) {
+ infos.addFreeObject(this.objectMapClassName.get(id));
+ this.unRegisterJavaObject(id);
+ } else {
+ infos.addKeptObject(this.objectMapClassName.get(id));
+ }
+ }
- public vtkJavaGarbageCollector getAutoGarbageCollector() {
- return this.garbageCollector;
+ this.lastGcResult = infos;
+ return infos;
+ } finally {
+ this.lock.unlock();
}
-
- // Thread safe
- public int deleteAll() {
- int size = this.objectMap.size();
- try {
- this.lock.lock();
- for (Long id : new TreeSet<Long>(this.objectMap.keySet())) {
- this.unRegisterJavaObject(id);
- }
- } finally {
- this.lock.unlock();
- }
- return size;
+ }
+
+ public vtkJavaGarbageCollector getAutoGarbageCollector() {
+ return this.garbageCollector;
+ }
+
+ // Thread safe
+ public int deleteAll() {
+ int size = this.objectMap.size();
+ try {
+ this.lock.lock();
+ for (Long id : new TreeSet<Long>(this.objectMap.keySet())) {
+ this.unRegisterJavaObject(id);
+ }
+ } finally {
+ this.lock.unlock();
}
+ return size;
+ }
- public int getSize() {
- return objectMap.size();
- }
+ public int getSize() {
+ return objectMap.size();
+ }
- public vtkReferenceInformation getLastReferenceInformation() {
- return this.lastGcResult;
- }
+ public vtkReferenceInformation getLastReferenceInformation() {
+ return this.lastGcResult;
+ }
}
Code Review / simantics / 3d.git / blobdiff