Method main

Wrapping/Java/Testing/Java/vtk/test/ConcurrencyGC.java:22–72

(String[] args)

public class ConcurrencyGC {

  public static void main(String[] args) throws InterruptedException, InvocationTargetException {
    try {
      vtkJavaTesting.Initialize(args, true);

      // Setup working runnable
      Runnable workingJob = new Runnable() {
        public void run() {
          try {
            vtkUnstructuredGrid grid = new vtkUnstructuredGrid();
            grid.SetPoints(new vtkPoints());
            vtkPoints p;
            long timeout = System.currentTimeMillis() + 60000; // +1 minute
            while (System.currentTimeMillis() < timeout) {
              p = grid.GetPoints();
              if (p == null) {
                throw new RuntimeException("Invalid pointer null");
              }
              if (p.GetReferenceCount() != 2) {
                throw new RuntimeException("Invalid reference count of " + p.GetReferenceCount());
              }
            }
          } catch (Throwable e) {
            e.printStackTrace();
            vtkJavaTesting.Exit(vtkJavaTesting.FAILED);
          }
        }
      };

      // Start threads for concurrency (2xwork + 1xGC + 1xGCinEDT)
      Thread worker1 = new Thread(workingJob);
      Thread worker2 = new Thread(workingJob);

      // Start working thread
      worker1.start();
      worker2.start();

      // Setup GC
      vtkJavaGarbageCollector gc = vtkJavaTesting.StartGCInEDT(10, TimeUnit.MILLISECONDS); // Start periodic GC in EDT
      new Thread(gc.GetDeleteRunnable()).start();                                          // Start GC in tight loop

      // If worker finished close everything
      worker1.join();
      worker2.join();
      gc.Stop();
      vtkJavaTesting.Exit(vtkJavaTesting.PASSED);

    } catch (Throwable e) {
      e.printStackTrace();
      vtkJavaTesting.Exit(vtkJavaTesting.FAILED);
    }
  }
}