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

• Реализовать стек, очередь и дэк на прототипах и замыканиях
• Реализовать стек через 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

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

constincoming=newQueue();constcalculating=newQueue();constpreparing=newQueue();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); // второй параметр - приоритет }