Jak dodać element do początku kolejki?

Question

Tworzę usługę Windows, która korzysta z FileSystemWatcher do monitorowania określonego folderu w celu dodania określonego typu pliku. Ze względu na lukę między utworzonym zdarzeniem, a plikiem, który jest faktycznie gotowy do manipulacji, utworzyłem kod Queue<T> do przechowywania nazw plików wymagających przetworzenia. W module obsługi zdarzeń Utworzono element jest dodawany do kolejki. Następnie za pomocą timera okresowo chwytam pierwszy element z kolejki i przetwarzam go. Jeśli przetwarzanie nie powiedzie się, element zostanie dodany do kolejki, aby usługa mogła ponowić przetwarzanie później.

To działa dobrze, ale odkryłem, że ma jeden efekt uboczny: pierwsza próba przetworzenia nowych elementów nie nastąpi, dopóki nie zostaną ponownie sprawdzone wszystkie stare elementy ponownej próby. Ponieważ jest możliwe, że kolejka może zawierać wiele elementów, chciałbym wymusić nowe pozycje na początku kolejki, aby były przetwarzane jako pierwsze. Ale z wersji Queue<T> documentation nie ma oczywistego sposobu dodawania elementu z przodu kolejki.

Przypuszczam, że mógłbym utworzyć drugą kolejkę dla nowych przedmiotów i przetworzyć tę preferencję, ale mając jedną kolejkę, wydaje się prostszy.

Czy istnieje łatwy sposób dodania elementu do początku kolejki?

Answer 1

To niby wygląda chcesz LinkedList<T>, który pozwala robić rzeczy jak AddFirst(), AddLast(), RemoveFirst() i RemoveLast().

Answer 2

Cóż, zgadzam się z CanSpice; Jednakże, można:

var items = queue.ToArray(); 
queue.Clear(); 
queue.Enqueue(newFirstItem); 
foreach(var item in items) 
    queue.Enqueue(item); 

Nasty hack, ale to będzie działać;)

raczej myślisz o dodanie drugiej instancji kolejce. Ten jest kolejką priorytetową, którą najpierw sprawdzasz/uruchamiasz. To byłoby trochę czystsze. Możesz nawet utworzyć własną klasę kolejki, aby wszystko było ładnie i schludnie;)

Answer 3

Brzmi tak, jakbyś chciał, to jest Stack - To jest bufor LIFO (ostatni w pierwszym wyjściu).

Answer 4

Po prostu użyj metody Peek w swoim oddzwanianiu timera zamiast Dequeue. Jeśli przetwarzanie powiedzie się, odznacz element.

Answer 5

Sugerowałbym użycie dwóch kolejek: jednej dla nowych przedmiotów i jednej dla ponownej próby. Oblewaj obie kolejek w jednym obiekcie, który ma taką samą semantykę jak kolejka, jeśli chodzi o usuwanie, ale umożliwia oznaczanie rzeczy jako przechodzenie do nowej kolejki lub kolejki Retry podczas wstawiania. Coś jak:

public class DoubleQueue<T> 
{ 
    private Queue<T> NewItems = new Queue<T>(); 
    private Queue<T> RetryItems = new Queue<T>(); 

    public Enqueue(T item, bool isNew) 
    { 
     if (isNew) 
      NewItems.Enqueue(item); 
     else 
      RetryItems.Enqueue(item); 
    } 

    public T Dequeue() 
    { 
     if (NewItems.Count > 0) 
      return NewItems.Dequeue(); 
     else 
      return RetryItems.Dequeue(); 
    } 
} 

Oczywiście, trzeba mieć właściwość Count która zwraca liczbę elementów w obu kolejek.

Jeśli masz więcej niż dwa typy przedmiotów, czas przejść na kolejkę priorytetową.

Answer 6

Potrzebujesz kolejki priorytetowej . Spójrz na C5 Collections Library. To IntervalHeap implementuje interfejs IPriorityQueue. Biblioteka kolekcji C5 jest całkiem dobra.

Wierzę, że można znaleźć implementacje pod numerami http://www.codeproject.com i http://www.codeplex.com.