logjam_parser_thread

/*
 * connections: n_w = NUM_WRITERS, n_p = NUM_PARSERS, "<" = connect, "o" = bind
 *
 *                            controller
 *                                |
 *                              PIPE
 *              PUSH    PULL      |        PUSH       PULL
 *  subscriber  o---------->  parser(n_p)  <-------------o  request_writer(n_w)
*/

// Q: Why do we connect to the writers instead of connecting the writers to the parser?
// A: I think this upside down, but was maybe caused by dropped requests.