1201                         e.execute(new ConsumerTask<T>(this));

  1201                         e.execute(new ConsumerTask<T>(this));

  1202                         break;

  1202                         break;

  1203                     } catch (RuntimeException | Error ex) { // back out

  1203                     } catch (RuntimeException | Error ex) { // back out

  1204                         do {} while (((c = ctl) & DISABLED) == 0 &&

  1204                         do {} while (((c = ctl) & DISABLED) == 0 &&

  1205                                      (c & ACTIVE) != 0 &&

  1205                                      (c & ACTIVE) != 0 &&

  1207                                      (this, c, c & ~ACTIVE));

  1207                                      (this, c, c & ~ACTIVE));

  1208                         throw ex;

  1208                         throw ex;

  1209                     }

  1209                     }

  1210                 }

  1210                 }

  1211             }

  1211             }