1 ------------------------------------------------------------------------------
3 -- GNAT LIBRARY COMPONENTS --
5 -- ADA.CONTAINERS.UNBOUNDED_PRIORITY_QUEUES --
9 -- Copyright (C) 2011-2016, Free Software Foundation, Inc. --
11 -- This specification is derived from the Ada Reference Manual for use with --
12 -- GNAT. The copyright notice above, and the license provisions that follow --
13 -- apply solely to the contents of the part following the private keyword. --
15 -- GNAT is free software; you can redistribute it and/or modify it under --
16 -- terms of the GNU General Public License as published by the Free Soft- --
17 -- ware Foundation; either version 3, or (at your option) any later ver- --
18 -- sion. GNAT is distributed in the hope that it will be useful, but WITH- --
19 -- OUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY --
20 -- or FITNESS FOR A PARTICULAR PURPOSE. --
22 -- As a special exception under Section 7 of GPL version 3, you are granted --
23 -- additional permissions described in the GCC Runtime Library Exception, --
24 -- version 3.1, as published by the Free Software Foundation. --
26 -- You should have received a copy of the GNU General Public License and --
27 -- a copy of the GCC Runtime Library Exception along with this program; --
28 -- see the files COPYING3 and COPYING.RUNTIME respectively. If not, see --
29 -- <http://www.gnu.org/licenses/>. --
31 -- This unit was originally developed by Matthew J Heaney. --
32 ------------------------------------------------------------------------------
35 with Ada
.Containers
.Ordered_Sets
;
36 with Ada
.Containers
.Synchronized_Queue_Interfaces
;
39 with package Queue_Interfaces
is
40 new Ada
.Containers
.Synchronized_Queue_Interfaces
(<>);
42 type Queue_Priority
is private;
44 with function Get_Priority
45 (Element
: Queue_Interfaces
.Element_Type
) return Queue_Priority
is <>;
48 (Left
, Right
: Queue_Priority
) return Boolean is <>;
50 Default_Ceiling
: System
.Any_Priority
:= System
.Priority
'Last;
52 package Ada
.Containers
.Unbounded_Priority_Queues
is
53 pragma Annotate
(CodePeer
, Skip_Analysis
);
56 package Implementation
is
58 -- All identifiers in this unit are implementation defined
60 pragma Implementation_Defined
;
62 -- We use an ordered set to hold the queue elements. This gives O(lg N)
63 -- performance in the worst case for Enqueue and Dequeue.
64 -- Sequence_Number is used to distinguish equivalent items. Each Enqueue
65 -- uses a higher Sequence_Number, so that a new item is placed after
66 -- already-enqueued equivalent items.
68 -- At any time, the first set element is the one to be dequeued next (if
69 -- the queue is not empty).
71 type Set_Elem
is record
72 Sequence_Number
: Count_Type
;
73 Item
: Queue_Interfaces
.Element_Type
;
76 function "=" (X
, Y
: Queue_Interfaces
.Element_Type
) return Boolean is
77 (not Before
(Get_Priority
(X
), Get_Priority
(Y
))
78 and then not Before
(Get_Priority
(Y
), Get_Priority
(X
)));
79 -- Elements are equal if neither is Before the other
81 function "=" (X
, Y
: Set_Elem
) return Boolean is
82 (X
.Sequence_Number
= Y
.Sequence_Number
and then X
.Item
= Y
.Item
);
83 -- Set_Elems are equal if the elements are equal, and the
84 -- Sequence_Numbers are equal. This is passed to Ordered_Sets.
86 function "<" (X
, Y
: Set_Elem
) return Boolean is
88 then X
.Sequence_Number
< Y
.Sequence_Number
89 else Before
(Get_Priority
(X
.Item
), Get_Priority
(Y
.Item
)));
90 -- If the items are equal, Sequence_Number breaks the tie. Otherwise,
91 -- use Before. This is passed to Ordered_Sets.
93 pragma Suppress
(Container_Checks
);
94 package Sets
is new Ada
.Containers
.Ordered_Sets
(Set_Elem
);
98 use Implementation
, Implementation
.Sets
;
100 protected type Queue
(Ceiling
: System
.Any_Priority
:= Default_Ceiling
)
103 is new Queue_Interfaces
.Queue
with
105 overriding
entry Enqueue
(New_Item
: Queue_Interfaces
.Element_Type
);
107 overriding
entry Dequeue
(Element
: out Queue_Interfaces
.Element_Type
);
109 -- The priority queue operation Dequeue_Only_High_Priority had been a
110 -- protected entry in early drafts of AI05-0159, but it was discovered
111 -- that that operation as specified was not in fact implementable. The
112 -- operation was changed from an entry to a protected procedure per the
113 -- ARG meeting in Edinburgh (June 2011), with a different signature and
116 procedure Dequeue_Only_High_Priority
117 (At_Least
: Queue_Priority
;
118 Element
: in out Queue_Interfaces
.Element_Type
;
119 Success
: out Boolean);
121 overriding
function Current_Use
return Count_Type
;
123 overriding
function Peak_Use
return Count_Type
;
127 -- Elements of the queue
129 Max_Length
: Count_Type
:= 0;
130 -- The current length of the queue is the Length of Q_Elems. This is the
131 -- maximum value of that, so far. Updated by Enqueue.
133 Next_Sequence_Number
: Count_Type
:= 0;
134 -- Steadily increasing counter
137 end Ada
.Containers
.Unbounded_Priority_Queues
;