在Java应用程序中,当需要处理大量原生资源时,如TensorFlow或PyTorch等深度学习库,可能会遇到JVM堆内存占用不高,但原生内存占用持续增长的问题。这通常是由于Java对象(如MemoryHandle)持有对原生资源的引用,而GC未能及时回收这些对象导致的。即使这些Java对象本身很小,但它们关联的原生资源可能非常庞大,导致应用程序的内存占用迅速膨胀。本文将介绍一种通过辅助GC来解决此类问题的方案。
问题的核心在于GC的触发机制。通常,GC的触发是基于JVM堆内存的占用情况。当JVM堆内存占用较低时,即使存在大量未被引用的MemoryHandle对象,GC也可能不会主动触发,从而导致关联的原生资源无法释放。
该方案的核心思想是:通过异步线程定期触发Full GC,并结合统计信息来优化GC的触发频率,从而在保证应用程序性能的同时,有效控制原生内存的占用。
创建一个后台线程,该线程定期检查是否需要触发Full GC。使用AtomicBoolean来控制GC的触发,避免频繁触发GC带来的性能损耗。
private final AtomicBoolean shouldRunGC = new AtomicBoolean(false); private final Thread gcThread = new Thread(() -> { while (true) { try { Thread.sleep(10); // 调整休眠时间,控制GC触发频率 } catch (InterruptedException e) { e.printStackTrace(); } if (shouldRunGC.getAndSet(false)) { System.gc(); // 触发Full GC } } }, "GC-Invoker-Thread"); { gcThread.setDaemon(true); gcThread.start(); }
在代码的关键位置(例如,释放原生资源后),收集已释放原生资源的统计信息。当释放的原生资源达到一定阈值时,设置shouldRunGC标志,触发异步GC。
public void dropHistory(ITensor tensor) {
// for all nodes now dropped from the graph
...
nBytesDeletedSinceLastAsyncGC += value.getNumBytes();
nBytesDeletedSinceLastOnSameThreadGC += value.getNumBytes();
...
if (nBytesDeletedSinceLastAsyncGC > 100_000_000) { // 100 Mb
shouldRunGC.set(true);
nBytesDeletedSinceLastAsyncGC = 0;
}
if (nBytesDeletedSinceLastOnSameThreadGC > 2_000_000_000) { // 2 GB
System.gc(); // 同步触发GC,更彻底但更耗时
nBytesDeletedSinceLastOnSameThreadGC = 0;
}
}为了进一步提升GC效率,可以结合以下JVM参数:
通过以上方案,可以在Java应用程序中有效地管理大型原生资源,避免内存泄漏,并保证应用程序的性能。