!7

cmodule RegexpMatcher > DynPrintLogAndEnabled {

  switchable bool verbose;

  transient L<Job> jobs = syncLinkedList();

  transient ReliableSingleThread rst = dm_rst_inInit(this, r step);

  // stats

  transient long jobsDone;

  transient Job shortestRegexp, longestRegexp;

  transient Job quickestJob, slowestJob;

  sclass Job {

    S regexp, input;

    bool ignoreCase;

    O whenDone; // voidfunc(Matcher, bool). called with null if error

    S moduleID; // for who are we doing this

    long executionTime; // after it ran

    void clean { whenDone = null; }

  }

  void step {

    Job job;

    while (licensed() && (job = syncPopFirst(jobs)) != null) pcall {

      doJob(job);

      job.clean();

      // update stats & print

      ++jobsDone;

      if (verbose) print("Regexp matching done in " + job.executionTime + " ms");

      shortestRegexp = switchIfShorterInField regexp(job, shortestRegexp,

        r { if (verbose) print("New shortest regexp!") });

      longestRegexp = switchIfLongerInField regexp(job, longestRegexp,

        r { if (verbose) print("New longest regexp!") });

      if (quickestJob == null || job.executionTime < quickestJob.executionTime) {

        quickestJob = job;

        if (verbose) print("New quickest job!");

      }

      if (slowestJob == null || job.executionTime > slowestJob.executionTime) {

        slowestJob = job;

        if (verbose) print("New slowest job!");

      }

    }

  }

  void doJob(Job j) {

    if (!dm_moduleExists(j.moduleID)) ret;

    long time = sysNow();

    Matcher m = null;

    bool found = false;

    pcall {

      m = safeRegexpPossiblyIC(j.ignoreCase, j.regexp, j.input);

      found = m.find();

    }

    j.executionTime = elapsedMS(time);

    callF(j.whenDone, m, found);

  }

  // API

  void addJob(S moduleID, S regexp, S input, bool ignoreCase, O whenDone) q {

    jobs.add(nu Job(+moduleID, +regexp, +input, +ignoreCase, +whenDone));
 // change();

    rst.trigger();

  }

  void deleteJobsForModule(S moduleID) q {

    syncFilterLinkedListInPlace(jobs, job -> eq(job.moduleID, moduleID));
 // change();

  }

}