REQREPLY-221: Add timeout to request reply cs example

Author: albertorobles2000

examples/connext_dds/request_reply/cs/PrimesProgram.cs

@@ -64,6 +64,16 @@ public static async Task Main(string[] args)
 
             // Set up signal handler to Dispose the DDS entities
             var cancellationSource = new CancellationTokenSource();
+            var timeoutTask = Task.Delay(TimeSpan.FromSeconds(arguments.Timeout), cancellationSource.Token)
+            .ContinueWith(_ =>
+            {
+                if (!cancellationSource.IsCancellationRequested)
+                {
+                    Console.WriteLine("Shutting down due to timeout...");
+                    cancellationSource.Cancel();
+                }
+            }, TaskScheduler.Default);
+
             Console.CancelKeyPress += (_, eventArgs) =>
             {
                 Console.WriteLine("Shutting down...");
@@ -100,6 +110,7 @@ private class Arguments
             public int Domain { get; set; }
             public int N { get; set; } = int.MaxValue;
             public int PrimesPerReply { get; set; }
+            public int Timeout { get; set; }
         }
 
         // Uses the System.CommandLine package to parse the program arguments.
@@ -124,7 +135,11 @@ private static Arguments ParseArguments(string[] args)
                 description: "The number to calculate primes up to (only applicable with --requester)"),
                 new System.CommandLine.Option<int>(
                     new string[] { "--primes-per-reply", "-p" },
-                getDefaultValue: () => 5)
+                getDefaultValue: () => 5),
+                new System.CommandLine.Option<int>(
+                    new string[] { "--timeout" },
+                getDefaultValue: () => 120,
+                description: "Timeout in seconds to wait for the application to finish")
             };
 
             rootCommand.Description = "Example RTI Connext Requester and Replier";