c++ - Check for input and sleep boost thread -


I am trying to create a thread that checks the user input and if the input is equal to "exit" So it stops all the other threads.

The way I use the cin is to stop the thread. Thread should run, check user input, and if there is one and this is equal to "exit", then close run process .

This is my code that does not work, is expected that "the new line is closed" is never printed, "Running" is printed only once: 

  void check_for_cin () {while (process runs) {cout & lt; & Lt; "Its going on"; String input; Std :: getline (std :: cin, input); // while (std :: getline (std :: cin, input)) {if (! Input.empty ()) {if (input == "exit") {runProcesses = false; Cout & lt; & Lt; "Out" & lt; & Lt; "Run processes:" & lt; & Lt; RunProcesses; }} Cout & lt; & Lt; "Newline closed"; Promotion :: this_thread :: sleep (boost :: posix_time :: seconds (1)); } Cout & lt; & Lt; "Not tested for input now"; }

How can I do this?

See file descriptor service objects of ASIO.

A 'reactor' style in POSX is uninitialized, so you do not really need thread to get asynchronicity.

The loop reading my example shows that the 'exit' has been typed / or / when a deadline expires (10s). 

  #include & lt; Boost / asio.hpp & gt; #include & lt; Boost / asio / posix / stream_descriptor.hpp & gt; Promotion :: ASO :: io_service my_io_service; Boost :: asio :: posix :: stream_descriptor (my_o_service, :: dup (STDIN_FILENO)); Promotion :: asio :: deadline_timer timer (my_io_service); // Timeout zero time-to-time indexing (boost :: system :: errorGode EC) {if (! Ec) std :: cerr & lt; & Lt; "Expired \ n"; Else if (ec == boost :: asio :: error :: operation_aborted) // Report this error timer.cancel () std :: cerr & lt; & Lt; "Initial departure :) \ n"; Else std :: cerr & lt; & Lt; "Getting Out for Any Other Reason:" & lt; & Lt; Ec.message () & lt; & Lt; "\ N"; Prevent reading loop in // cancell (); In.close (); } // set timeout timer zero arm_timeout () {timer.expires_from_now (boost :: posix_time :: seconds (10)); Timer.async_wait (timeout_expired); } // display loop without read_loop () {std :: cerr & lt; & Lt; "(Input is ...) \ n"; Steady boost: asio :: streambuff buffer; // some encapsulation :) async_read_until (in, buffer, '\ n', [& amp;] (boost :: system :: errorGode EC, size_t bytes_transfer) {if (! Ec) {std :: string line; std: : Istream (& amp; buffer); if (std :: getline (line, & amp; amp; amp; amp; line == & quot; exit & quot;) ec = boost :: asio :: error :: operation_aborted; else read_loop (); / / Release} if (EC) {std :: cerr & lt; "are going out for this reason:"

On the windows, you can use the equivalent

You can add threads by running my_io_service.run () on more than one Are the thread


Comments

Post a Comment

Popular posts from this blog

ios - How do I use CFArrayRef in Swift? -

I am using Objective-class in my Swift Project through a bridging header. The method signature looks like this: - Some cement (some type) some parameters; I started by getting an example of class, calling method, and storing the value: var myInstance = MyClassWithThatMethod (); Var cfArr = myInstance.someMethod (some value); Then try to get the value in the array: var valueInArrayThatIWant = CFArrayGetValueAtIndex (cfArr, 0); However, I get the error unmanaged & lt; Cfarray & gt; Not like 'CFArray' . Unmanaged & lt; Cfarray & gt; also means? I looked, but I do not need to change the array in a fast array (though it would be good). I need to be able to get value from the array. I also tried CFArray method to pass in a function: func doSomeStuffOnArray (myArray: NSArray) {} Although I get the same error when using: doSomeStuffOnArray (cfArr); // unmanaged & lt; CFArray & gt; I am using CFArray because I want to sto...
Read more

eclipse plugin - Run java code error: Workspace is closed -

To create an automated project, I created a plug-in project with the following dependencies: Org.eclipse.core.resources org.eclipse.equinox.registry org.eclipse.core.runtime and the following The Java class is located in the src folder: Package Examiner; Import org.eclipse.core.resources.IProject; Import org.eclipse.core.resources.IWorkspaceRoot; Import org.eclipse.core.resources.ResourcesPlugin; Import org.eclipse.core.runtime.CoreException; Import org.eclipse.core.runtime.IProgressMonitor; Import org.eclipse.core.runtime.NullProgressMonitor; Public class tes {public static zero main (string [] args) {// TODO auto generated method stub IProgressMonitor progress monitor = new NullProgressMonitor (); IWorkspaceRoot root = ResourcesPlugin.getWorkspace (). GetRoot (); Ipoject project = root.jetproject ("desired projectname"); Try {Project.create (progress monitor); Project.open (progressMonitor); } Grip (CoreException E) {// TODO Auto generated blocking block e....
Read more

c - Error on building source code in VC 6 -

When I create my project in VC6, the BScMKE reports the following error Linking .. Creating Library ... .. / ... / PB / Bean / Debub / ICEERP.Lib and Object ........ P.B. / Bean / DBube / ICREPlay.APP Browse information file ... BSMMK: ​​error can not be read from BK 1505: file '../../PB/bin/TmpOut/ICReplay/Debug/ICReplay_PB.bsc' Error executing bscmake.exe Can someone help me? 2 Reason for reference from: "ICReplay_PB .bsc "file will be corrupted The trunk of the file will be happening with the compiler running out of disk space or is being interrupted when creating .sbr file I think this answer will help you!
Read more