summaryrefslogtreecommitdiff
path: root/src/01/01a/priority_queue.c
blob: e4d94a74b528654cc011563b01b5ce8b431edf26 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
#include "priority_queue.h"
#include <stdlib.h>

PriorityQueue *initialize() {
  PriorityQueue *queue = malloc(sizeof(PriorityQueue));
  queue->size = 0;
  queue->head = NULL;
  return queue;
}

static Node *create_node(int priority, int data) {
  Node *node = malloc(sizeof(Node));
  node->priority = priority;
  node->data = data;
  node->next = NULL;
  return node;
}

// This function is constant time O(1)
int size(PriorityQueue *queue) {
  return queue->size;
}

static int compare(const int x, const int y) {
  return x == y ? 0 : x > y ? 1 : -1;
}

void enqueue(Node *self, int priority, int data) {
  if (self->next == NULL) {
    self->next = create_node(priority, data);
    return;
  }

  int comparison = compare(self->next->priority, priority);
  if (comparison == 0) {
    return enqueue(self->next, priority, data);
  }

  if (comparison < 0) {
    return enqueue(self->next, priority, data);
  }

  self->next = create_node(priority, data);
}

// This function is linear time O(n)
void add(PriorityQueue *queue, int priority, int data) {
  queue->size++;

  if (!queue->head) {
    queue->head = create_node(priority, data);
    return;
  }

  if (compare(queue->head->priority, priority) <= 0)
    return enqueue(queue->head, priority, data);

  Node *node = create_node(priority, data);
  node->next = queue->head;
  queue->head = node;
}

// This function is constant time O(1)
int delete_min(PriorityQueue *queue) {
  if (queue->head) {
    Node *tmp = queue->head;
    int data = tmp->data;
    queue->head = tmp->next;
    queue->size--;
    free(tmp);
    return data;
  }
  return 0;
}

void destroy(PriorityQueue *queue) {
  Node *current = queue->head;
  Node *tmp;

  while(current) {
    tmp = current, current = current->next;

    if (tmp) free(tmp);
  }
  free(queue);
}