| 504 | |
| 505 | template <typename TaskType> |
| 506 | Queue<TaskType>::Queue( |
| 507 | const typename SharedBatchScheduler<TaskType>::QueueOptions& options, |
| 508 | Env* env, ProcessBatchCallback process_batch_callback, |
| 509 | SchedulableBatchCallback schedulable_batch_callback) |
| 510 | : options_(options), |
| 511 | env_(env), |
| 512 | process_batch_callback_(process_batch_callback), |
| 513 | schedulable_batch_callback_(schedulable_batch_callback) { |
| 514 | // Create an initial, open batch. |
| 515 | batches_.emplace_back(new Batch<TaskType>); |
| 516 | } |
| 517 | |
| 518 | template <typename TaskType> |
| 519 | Queue<TaskType>::~Queue() { |