java - Threading HttpUrlConnection -

-

i have 10 lists contains location data, each list has 10.000 entries. starting executerservice thread work.

executorservice executor = executors.newfixedthreadpool(locationlocationlist.size());  for(list<location> locationlist: locationlocationlist){     executor.execute(new testthread(locationlist)); }

it takes soo long finish work, in 10 threads. expensive part seems 1 open url , connect it. idea how can tune this?

@override         public void run() {             while(isrunning){                 gson gson = new gson();              map<integer, data> map= new hashmap<integer, data>();              for(location location: locations){                 string data = getjson(location.getlatitude(), location.getlongitude());                 data data= gson.fromjson(data, data.class);                 map.put(location.getid(), data);              }               weatherdao.setweatherfast(map);             isrunning = false;         }                            }      private string getjson(double latitude, double longitude) {         httpurlconnection httpurlconnection = null;          try {             url u = new url("someurl"+latitude+""+longitude);             httpurlconnection = (httpurlconnection) u.openconnection();             httpurlconnection.setrequestmethod("get");             httpurlconnection.setrequestproperty("content-length", "0");             httpurlconnection.connect();             int status = httpurlconnection.getresponsecode();              switch (status) {                 case 200:                 case 201:                     bufferedreader br = new bufferedreader(new inputstreamreader(httpurlconnection.getinputstream()));                     stringbuilder sb = new stringbuilder();                     string line;                      while ((line = br.readline()) != null) {                         sb.append(line+"\n");                     }                     br.close();                     return sb.tostring();             }          } catch (exception ex) {            logger.error("couldnt data", ex);         }          return "";     }

steps follow:

  • store result of getjson() method based on latitude , longitude.

  • for each call first check in stored map if found there no need call getjson() method again.

i hope if latitude , longitude repeating.

sample code:

 map<string,string> cache = new concurrenthashmap<string,string>();   key (latitude + "_" + longitude) , value (data)

keep in mind cache using in multi-threading.


Comments

Post a Comment

Popular posts from this blog

c# - Unity IoC Lifetime per HttpRequest for UserStore -

-
i'm trying clean default implementation of accountcontroller.cs comes out of box in new mvc5/owin security implementation. have modified constructor this: private usermanager<applicationuser> usermanager; public accountcontroller(usermanager<applicationuser> usermanager) { this.usermanager = usermanager; } also, have created lifetime manager unity looks this: public class httpcontextlifetimemanager<t> : lifetimemanager, idisposable { private httpcontextbase _context = null; public httpcontextlifetimemanager() { _context = new httpcontextwrapper(httpcontext.current); } public httpcontextlifetimemanager(httpcontextbase context) { if (context == null) throw new argumentnullexception("context"); _context = context; } public void dispose() { this.removevalue(); } public override object get...
Read more

Change the color of an oval at click in Java AWT -

-
i have draw ovals in java, , @ click change color. beginning tried change color after 20 ms, doesn't work. my code is: public class mycomponentnew extends frame { public graphics2d g2d; public mycomponentnew(string title) { super(title); setsize(400, 550); } @override public void paint(graphics g) { this.g2d = (graphics2d) g; this.g2d.setcolor(color.red); this.g2d.filloval(10, 55, 50, 100); } public void changecolor () { this.g2d.setcolor(color.blue); this.g2d.filloval(10, 55, 50, 100); } } and in class main method have: mycomponentnew m; m = new mycomponentnew("fereastra cu baloane"); m.setvisible(true); m.addwindowlistener(new windowadapter() { @override public void windowclosing(windowevent we) { system.exit(0); } }); try { thread.sleep(20); } catch(interruptedexception e) {} m.changecolor(); the color of oval remains red. ...
Read more

I am trying to solve the error message 'incompatible ranks 0 and 1 in assignment' in a fortran 95 program. -

-
i writing program in fortran find velocity of parachuting person in relation time. keep getting error can't fix. new programming , appreciated. the error is v(i+1)=v(i)+[32-((c*v(i)*v(i))/m)]*(h) 1 error: incompatible ranks 0 , 1 in assignment @ (1) and program is program para integer :: real :: v(11) !velocity real :: q !initial velocity real :: h !time step real :: c !drag coefficient real :: m !mass ! gravity equal 32 ft/s^2 write (*,*)'enter time step' read(*,*)h write(*,*)'enter initial velocity' read(*,*)q write(*,*)'enter drag coefficient' read(*,*)c write(*,*)'enter mass' read(*,*)m i=1,10 ! 1 10, 1 being interval. end v(i+1)=v(i)+[32-((c*v(i)*v(i))/m)]*(h) q=v(1) end program you cannot use [] normal parenthesis in expressions. array constructor, [ items ] means array items elements. end do should after line.
Read more