executorservice - Spring Integration - If Poller and TaskExecutor are not in tune then memory leak -

-

in below 7.1.7 asynchronous polling section of spring integration doc, memory leak might occur if poller , taskexecutor not in tune explained. did not understand it.

http://docs.spring.io/autorepo/docs/spring-integration/3.0.x/reference/html/messaging-endpoints-chapter.html#async-polling

<int:service-activator input-channel="publishchannel" ref="myservice">     <int:poller receive-timeout="5000" task-executor="taskexecutor" fixed-rate="50"/> </int:service-activator>  <task:executor id="taskexecutor" pool-size="20" queue-capacity="20"/>

the above configuration demonstrates 1 of out of tune configurations.

the poller keeps scheduling new tasks though threads blocked waiting either new message arrive, or timeout expire. given there 20 threads executing tasks 5 second timeout, executed @ rate of 4 per second (5000/20 = 250ms). but, new tasks being scheduled @ rate of 20 per second, internal queue in task executor grow @ rate of 16 per second (while process idle), have memory leak.

one of ways handle set queue-capacity attribute of > task executor 0.

can please elaborate it.

here understanding of above code:

pool-size 20 - 20 threads execute.

receive-timeout 5 seconds: 20 threads given 5 seconds complete tasks.

fixed rate 50 ms - new tasks being scheduled @ rate of 20 per second.

i have few questions:

q. happen if takes more 5 seconds execute 20 threads?

q. in doc, said tasks executed @ rate of 4 per second. but, tasks might run in less 4 seconds , take more time.

q. how causes memory leak? if there no threads , queue available, executor rejects per rejection policy instead.

q. how setting queue-capacity 0 helps here? per understanding, if threads busy executor put them in queue until reaches queue-capacity.

the documentation incorrect - memory leak if have unbounded queue , message processing can't keep up. opened jira issue correct it.


Comments

Post a Comment

Popular posts from this blog

qt - Using float or double for own QML classes -

-
i've created components , helper methods using c++ , qt used in qml gui. of methods calculate gui elements (size, transformations, scene graph items creation). target arm 32 bit using opengl / eglfs render output. opengl using float , qml using real (defined double ). what should use in c++ do not lose precision? if use qreal ( double ) shouldn't lose precision. if git grep float in qtbase.git , can find out bit more: dist/changes-5.2.0-**************************************************************************** dist/changes-5.2.0-* important behavior changes * dist/changes-5.2.0-**************************************************************************** dist/changes-5.2.0- dist/changes-5.2.0- - qt compiled qreal typedef'ed double on dist/changes-5.2.0: platforms. qreal float on arm chipsets before. guarantees more dist/changes-5.2.0- consistent behavior between platforms qt supports, binary dist/chan...
Read more

Create Outlook appointment via C# .Net -

-
i need create outlook appointment using microsoft.office.interop.outlook , while can work locally on own workstation , works if run web application via server's browser, not work when connect server externally. hence, think might permission issue. i changed application pool identity " localsystem " don't access denied error. unfortunately, doesn't work. the app behaves if appointment created, appointment doesn't appear in outlook. here include file on top of aspx.cs page using outlook = microsoft.office.interop.outlook; here code using pop appointment. outlook.application apptapp = new outlook.application(); outlook.appointmentitem appt = apptapp.createitem(outlook.olitemtype.olappointmentitem) outlook.appointmentitem; appt.subject = txtfirstname.text + " " + txtlastname.text; appt.body = txtcomment.text; appt.alldayevent = false; appt.start = datetime.parse(txtreminderdate.text + " 8:00 am"); appt.end = datetime.p...
Read more

ios - Swift Array Resetting Itself -

-
i have 2 arrays: pointhistory , datehistory . have nstimer , , when timer runs out, action called. in action appending int pointhistory , , current date string datehistory . here timer action: func timeraction() { let steppervalue = int(stepper.value) employee.numberofpoints = steppervalue networking.saveemployee(employee, completion: { (error) -> void in if error != nil { let alert = uialertcontroller(title: "error", message: "there error updating \(self.employee.name)'s points", preferredstyle: .alert) let alertaction = uialertaction(title: "ok", style: .cancel, handler: nil) alert.addaction(alertaction) self.presentviewcontroller(alert, animated: true, completion: nil) } }) var dateformatter = nsdateformatter() dateformatter.dateformat = "mm-dd-yyyy" dateformatter.timezone = nstimezone.localtimezone() var date = nsdate() var ...
Read more