Advertisement
Guest User

Untitled

a guest
Aug 21st, 2017
72
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.73 KB | None | 0 0
  1. ConcurrentQueue<packet> queue = new ConcurrentQueue<packet>();
  2.  
  3. while(true){
  4. packet data;
  5. if (!queue.TryPeek(out packet)) continue;
  6. send(data);
  7. queue.TryDequeue(out data); //remove sent packet from the queue
  8. }
  9.  
  10. public struct packet
  11. {
  12. public byte[] data;
  13. public uint Length;
  14. public address addr;
  15. public string priority;
  16. }
  17.  
  18. while(true){
  19. packet data;
  20. if (!queue.TryPeek(out packet)) continue;
  21. foreach(packet x in queue)
  22. {
  23. if(x.priority == "high")
  24. {
  25. send(data);
  26. queue.TryDequeue(out data);
  27. }
  28. }
  29. send(data);
  30. queue.TryDequeue(out data);
  31. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement