<br />
<b>Warning</b>:  session_start(): open(/var/lib/php/sessions/sess_rvkupv4u7dndh9ked9i366p5rp, O_RDWR) failed: No space left on device (28) in <b>/var/www/tb-usercake/models/config.php</b> on line <b>51</b><br />
<br />
<b>Warning</b>:  session_start(): Failed to read session data: files (path: /var/lib/php/sessions) in <b>/var/www/tb-usercake/models/config.php</b> on line <b>51</b><br />
static class Q implements AutoCloseable {
  S name = "Unnamed Queue";
  BlockingQueue<Runnable> q = new LinkedBlockingQueue;
  volatile bool retired;
  
  static class Done extends RuntimeException {}
  
  *() {}
  
  *(bool startThread) {
    if (startThread) startThread();
  }
  
  *(String *name, boolean startThread) {
    if (startThread) startThread();
  }
  
  Runnable _mainRunnable() {
    ret r { Q.this.run(); };
  }
  
  Thread startThread() {
    ret _startThread(name, _mainRunnable());
  }
  
  Thread startDaemonThread() {
    ret _startThread(newDaemonThread(name, _mainRunnable()));
  }
  
  Iterable<Runnable> master() {
    return new Iterable<Runnable>() {
      public Iterator<Runnable> iterator() {
        return new Iterator<Runnable>() {
          Runnable x;
          
          public boolean hasNext() ctex {
            //debug("hasNext");
            while (x == null && licensed() && !retired)
              x = q.poll(1, TimeUnit.SECONDS);
            //debug("hasNext true");
            return true;
          }
          
          public Runnable next() {
            if (!licensed() || retired) null;
            //debug("next");
            hasNext();
            Runnable _x = x;
            x = null;
            //debug("next " + structure(x));
            return _x;
          }
          
          public void remove() {
          }
        };
      }
    };
  }
  
  void add(Runnable r) {
    q.add(r);
  }
  
  void add(O r) {
    q.add(toRunnable(r));
  }
  
  void run() {
    for (Runnable r : master()) {
      if (!licensed() || retired) ret;
      try {
        r.run();
      } catch (Done e) {
        ret; // break signal
      } catch (Throwable e) {
        printStackTrace(e);
      }
    }
  }
  
  void done() {
    add(r { throw new Done; });
  }
  
  public void close() { retired = true; } // TODO: interrupt thread
}