multithreading - Scala Play thread -


i'm using scala / play2 framework / mongodb (reactivemongo) have function in request doing : find maximum value in collection, increase maximum number random, , save new value collection, , return new value.

def generatecode():future[string] = {   // find maximum   maximum = future[].... map { maxvalue =>       // increase maxvalue       newvalue = maxvalue + random       // save database   } }

the problem want code 1 thread run @ time. because if 2 thread run same time, value con conflicted. example: thread 1: read max = 100, thread 2 read max = 100 thread 1: increase max = 105, thread 2 increase max = 102 thread 1: save 105 db, thread 2 save 102 db

finally maximum in db 102, in should 105. how can ?

as rule reactivemongo api , operations on future require implicit executioncontext in scope. can define single threaded execution context , use in class defined generatecode() method , in class call reactivemongo api.

import java.util.concurrent.executors  implicit val ec: executioncontext = executioncontext.fromexecutor(executors.newsinglethreadexecutor())

you can pass ec explicitly methods require implicit executioncontext. need make sure whole chain of asynchronous method calls uses same single threaded execution context.


-

Popular posts from this blog

Apache NiFi ExecuteScript: Groovy script to replace Json values via a mapping file -

i working apache nifi 0.5.1 on groovy script replace incoming json values ones contained in mapping file. mapping file looks (it simple .txt): header1;header2;header3 a;some text;a2 i have started following: import groovy.json.jsonbuilder import groovy.json.jsonslurper import java.nio.charset.standardcharsets def flowfile = session.get(); if (flowfile == null) { return; } flowfile = session.write(flowfile, { inputstream, outputstream -> def content = """ { "field1": "a" "field2": "a", "field3": "a" }""" def slurped = new jsonslurper().parsetext(content) def builder = new jsonbuilder(slurped) builder.content.field1 = "a" builder.content.field2 = "some text" builder.content.field3 = "a2" outputstream.write(builder.toprettystring().ge...
Read more

python 3.x - PyQt5 - Signal : pyqtSignal no method connect -

following example in doc found on sourceforge faced error. from pyqt5.qtcore import pyqtsignal, pyqtslot def setsignal(): signal = pyqtsignal() signal.connect(self.myaction) @qtcore.pyqtslot() def myaction(): print("signal triggered") results in attributeerror: 'pyqt5.qtcore.pyqtsignal' object has no attribute 'connect' as mentioned in docs linked, signal needs defined on class level: class foo(qobject): signal = pyqtsignal() def connectsignal(): self.signal.connect(self.myaction) @qtcore.pyqtslot() def myaction(): print("signal triggered")
Read more