Stack, Queue and Dequeue

Задания (на выбор):

• Реализовать стек, очередь и дэк на прототипах и замыканиях
• Реализовать стек через 2 класса (Stack + Element), то же и с очередью и дэком
• Добавить протокол iterable
  • см. про next() и Symbol.iterator
• Сделать методы и свойства:
  • Клонирование .clone():list
  • Очистка .clear()
  • Кол-во элементов .size
• Реализовать события (чтоб можно было на них подписываться, но чтоб cнаружи нельзя было делатьemit):
  • .on('push', (element, dequeue) => {})
  • .on('pop', (element, dequeue) => {})
  • .on('unshift', (element, dequeue) => {})
  • .on('shift', (element, dequeue) => {})
  • Когда дэк опустошен .on('drain', (dequeue) => {})
• Взять односвязный или двусвязный список и унаследовать от него стек, очередь и дэк
• Взять односвязный или двусвязный список и на базе их построить стек, очередь и дэк через механизм агрегированяи (делегирования)
• Добавить в очерез таймаут ожидания в очереди queue.timeout(msec)
• Добавить в очередь работу с приоритетами (упорядочить очередь по приоритету)
• Реализовать очередь с приоритетами на базе массива и дерева
• Асинхронные аналоги
  • .pop((data) => {})
  • .shift((data) => {})
  • аналоги на Promise

Построение цепочек из очередей:

const incoming = new Queue();
const calculating = new Queue();
const preparing = new Queue();

incoming.process(item => item).pipe(calculating);
calculating.process(item => item).pipe(preparing);
preparing.process(item => {
  console.log(item);
});

Реализация стека со сбором статичтики на замыканиях

const q = queue();

// Используем при помощи методов
q.put(obj1);
q.pick((obj2) => { });

// Выводим статистику использования
console.dir(q);

/* {
  elapsedTime: 12783, // время существования стека
  processed: 1773, // кол-во было обработано всего
  processing: 29, // кол-во обрабатывается сейчас
  minTime: 6, // минимальное время элемента в стеке
  maxTime: 1720, // максимальное время элемента в стеке
  averageTime: 803, // среднее время с стеке
} */

Реализация конкурентной очереди с приоритетами и трехканальной обработкой с таймаутами на замыканиях (реализация СМО, системы массового обслуживания)

const q = queue(3).timeout(2000);

q.process((item, callback) => {
  process.nextTick(() => {
    console.log(item);
    callback();
  });
});

q.drain(() => {
  console.log('Queue drain');
});

for (let i = 0; i < 10; i++) {
  q.add({ i }, i % 2); // второй параметр - приоритет
}