TQueue: new primitive to take a snapshot of the queue

1 files changed, 6 insertions, 0 deletions

diff --git a/stm/tQueue.mli b/stm/tQueue.mli
index c006b6a867..abb14f969d 100644
--- a/stm/tQueue.mli
+++ b/stm/tQueue.mli
@@ -14,7 +14,13 @@ val pop : 'a t -> 'a
 val push : 'a t -> 'a -> unit
 val set_order : 'a t -> ('a -> 'a -> int) -> unit
 val wait_until_n_are_waiting_and_queue_empty : int -> 'a t -> unit
+
+(* also empties the queue *)
 val dump : 'a t -> 'a list
+
+(* Non destructive *)
+val wait_until_n_are_waiting_then_snapshot : int -> 'a t -> 'a list
+
 val clear : 'a t -> unit
 val is_empty : 'a t -> bool