Ticket Reference handling #1048

Paul Martin

2016-04-27 c2188a840bc4153ae92112b04b2e06a90d3944aa

 src/main/java/com/gitblit/utils/WorkQueue.java

@@ -51,17 +51,19 @@

  private Executor defaultQueue;
  private final IdGenerator idGenerator;
  private final int defaultQueueSize;
  private final CopyOnWriteArrayList<Executor> queues;

  public WorkQueue(final IdGenerator idGenerator) {
  public WorkQueue(final IdGenerator idGenerator, final int defaultQueueSize) {
    this.idGenerator = idGenerator;
    this.defaultQueueSize = defaultQueueSize;
    this.queues = new CopyOnWriteArrayList<Executor>();
  }

  /** Get the default work queue, for miscellaneous tasks. */
  public synchronized Executor getDefaultQueue() {
    if (defaultQueue == null) {
      defaultQueue = createQueue(1, "WorkQueue");
      defaultQueue = createQueue(defaultQueueSize, "WorkQueue");
    }
    return defaultQueue;
  }