Method run

core/src/main/java/io/ddf/util/PhantomReference.java:58–72

()

    Thread referenceThread = new Thread() {
      public void run() {
        while (true) {
          try {
            PhantomReference ref = (PhantomReference) referenceQueue.remove();

            LOG.info(String.format("GC removing %s (%s) from memory", ref.getClass().getName(), ref.hashCode()));

            ref.cleanup();
            phantomReferences.remove(ref);
          } catch (Exception ex) {
            // log exception, continue
            LOG.error("Error while cleaning up reference queue", ex);
          }
        }
      }
    };
    referenceThread.setDaemon(true);
    referenceThread.start();