46     startTimer()
  47     {
  48         if (seconds <= 0) {
  49             return;
  50         }
  51 
  52         final Timer timer = new Timer();
  53         timer.schedule(new TimerTask() {
  54             public void run() {
  55                 done.set(true);
  56                 timer.cancel();
  57             }
  58         }, seconds * 1000L);
  59     }
  60 
  61     private static void
  62     sampleAggregate(Consumer consumer) throws DTraceException
  63     {
  64         while (consumer.isRunning() && !done.get()) {
  65             try {
  66                 Thread.currentThread().sleep(50);
  67             } catch (InterruptedException e) {
  68             }
  69 
  70             consumer.getAggregate(Collections. <String> emptySet());
  71         }
  72     }
  73 
  74     private static void
  75     startAggregateThread(final Consumer consumer)
  76     {
  77         Runnable aggregateSampler = new Runnable() {
  78             public void run() {
  79                 Thread t = Thread.currentThread();
  80                 getAggregateThreadID.set(t.getId());
  81                 Throwable x = null;
  82                 try {
  83                     sampleAggregate(consumer);
  84                 } catch (Throwable e) {
  85                     x = e;
  86                 }

  46     startTimer()
  47     {
  48         if (seconds <= 0) {
  49             return;
  50         }
  51 
  52         final Timer timer = new Timer();
  53         timer.schedule(new TimerTask() {
  54             public void run() {
  55                 done.set(true);
  56                 timer.cancel();
  57             }
  58         }, seconds * 1000L);
  59     }
  60 
  61     private static void
  62     sampleAggregate(Consumer consumer) throws DTraceException
  63     {
  64         while (consumer.isRunning() && !done.get()) {
  65             try {
  66                 Thread.sleep(50);
  67             } catch (InterruptedException e) {
  68             }
  69 
  70             consumer.getAggregate(Collections. <String> emptySet());
  71         }
  72     }
  73 
  74     private static void
  75     startAggregateThread(final Consumer consumer)
  76     {
  77         Runnable aggregateSampler = new Runnable() {
  78             public void run() {
  79                 Thread t = Thread.currentThread();
  80                 getAggregateThreadID.set(t.getId());
  81                 Throwable x = null;
  82                 try {
  83                     sampleAggregate(consumer);
  84                 } catch (Throwable e) {
  85                     x = e;
  86                 }