multithreading - Interrupt the thread which is making HTTP call in Java -

-

I am writing a Java program to make an HTTP call in a separate thread. The following code I am implementing in a separate call-able function in the thread pool provider. 

  MyRunnable Public Stabilized Classes Enforces Callback & lt; Boolean & gt; {@Override Public Boolean Call () {HttpURLConnection conn = null; {URL url = Try new URL ("http://www.myserver.com"); Conn = (HttpURLConnection) url.openConnection (); Conn.setConnectTimeout (5000); Conn.setReadTimeout (5000); Conn.setRequestMethod ("GET"); Int response = conn.getResponseCode (); Return reaction == 200; } Hold (IOException e) {e.printStackTrace (); return false; } Hold (exception e) {e.printStackTrace (); return false; }}}   
 For some reason, the server does not respond or the server responds very slowly. Due to the behavior of this server, both connections are time-consuming and do not have time to read  
 So I want to monitor this work (thread is running in the pool executor), and the thread is something It is time to interrupt and ensure that I remove this work from the pool so that this work is not done in the thread pool and free.   
  
 
 
 
 
 
 
 
 
  
 
 
 
 
 
 2, 5, 5, time unit. SEODNS, new Arrawlocking Q & A; runnable & gt; (10)); Future & lt; Boolean & gt; F = tpe.submit (new MyRunnable ()); Try {Boolean breakthrough = F. Jacket (5000, Time UNNET; MILILXNDNS); } Hold (exception e) {e.printStackTrace (); }   
   
  from timeout exposure  to  f.get  call after 5000 milliseconds if The thread that does not respond to  MyRunnable  work. But I can see that this work is going on in the thread pool provider, if it is stuck on  HttpURLConnection.getResponseCode () .  
 When I tried  f. Cancel (true) , this is not interfering with thread when the task  HttpURLConnection.getResponseCode ()  method gets stuck in the call. I think the thread will be interrupted only when it will be testing it for the next available opportunities. So I think that  future.cancel  does not help in this case.  
 How do I remove this call (by talking to the thread pool executor) and make sure that the work is removed from the pool and the related thread is free to handle different tasks?  
 Thanks for the reply.  
 Thanks,  
 Raghu   
 
 
 I think that You can share the connection with another thread, which will call disconnect () on the deadline after it, so it should be something like this:  
  Fixed class connection stapler applies Runnable {Private Final HttpURLConnection Conn; Connection Installer (HTTPPLRL Connection Connection) {If (Conne == blank) {New Nulloinction Exception (Throw); } This.conn = conn; } @ Override Public Wide Run () {conn.disconnect (); }} ... ScheduledExecutorService Service = Executor. NewScheduledThreadPool (THREAD_POOL_SIZE); ... // submit your own, submit, then a connectionstopper service. Schedule (New Connection Lock (Conn.), 5, Time Unit. SEODNSS);

Comments

Post a Comment

Popular posts from this blog

Pass DB Connection parameters to a Kettle a.k.a PDI table Input step dynamically from Excel -

-
Image
I have a requirement whenever I run my own kettle, dynamically took database connection parameters from an excel source Every run should go. I have an Excel column names: hostname, username, database, password. I want to pass these connection parameters to my table input stage dynamically whenever it runs the job. This is what I was trying to do. You can get it Connection parameters from the DB reading source (for example Excel or a CSV file in my example) < / Li> Store the parameters in the variable Using the variable in your connection's settings. Setting Variables Create another conversion for (you can not do it in the same conversion Uses): set variables element variable: The element that reads / writes your data creates a new connection and sets the connection parameter using $ {variable name_} Note that you will need to type in the field field in the field $ {password} Also keep in mind that this can be a security problem as the
Read more

multithreading - PhantomJS-Node in a for Loop -

-
I am trying to implement a screen-scraps application that opens a URL in which a parameter changes as it is for a loop: var data = [ '100', '101', '102', '103', '104']; (Var indexA = 0; indexA & lt; data.length; indexA ++) for {Phantom Generation ({'port': freeport}, function (pH) {ph.create page (function (page) {page.open ("http: //...++ data [index B] +" ... " , Status {console.log ("open site:" + data [index B], position); / * OLD * / indexB ++; page evaluation (function () {// page scrape and an object Return}, function {console.log (result.dataRequest); // here is the problem}); / * new and fixed * / indexB ++} first console Logs it: Open Site: 100 Success Opens Site: 101 Success B Ola Site: 102 Success Opening Site: 103 Success Opened Site: 104 Success Which is good. Data is verified in scrap HTML and from index to array Matches. So in page 101 I scrap '101 and retrieve' and pu
Read more

c++ - MATLAB .m file to .mex file using Matlab Compiler -

-
I know that it can speak as a very famous topic, but something that helps me with it Not found This scenario is: I have my functions function, no matter what's inside, it's a generic function that may depend on other toolboxes. Does. Has input and output; I want to generate the same myFun.mex function; : Lib myFun This way I get some new files: libmyfun.c libmyfun.dll Libmyfun.exp libmyfun.exports libmyfun .h libmyfun.lib Reading around and I think that Creating a myfun.cpp that is very famous is included: / * gateway function * / zero max function (ent NLHS, MXARRA * PLS [], int NRHS, CONST M Xeray * PHS []) Here is the Variable Deals * / / * code here * /} I have tried to do this and are called Regular of Max Generation: Max ('- v', 'myfun.cpp') But I get many errors, and I should say that my myfun.cpp copy / Paste Function is where I have a lot of doubts ... especially on input / output management. My q
Read more