温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

Scala的Akka编程中代码保持线程安全的重要性

发布时间:2020-07-02 03:57:47 来源:网络 阅读:2620 作者:金明略 栏目:开发技术

今天我提交我的远程分支合并到git orgin/master的请求,亮哥给了我一些指导。


亮哥 started a discussion on the diff

web/datacloud-web/app/com/mininglamp/datacloud/web/handler/db/DBUserHandler.scala

37

36}.flatMap {
3837_.headOption match {
3938case Some(x) => Future.failed(UserAlreadyExists(x.username))
40
-          case None => Future.successful(u.username)

39+          case None => {

40+            db.run {

41+              DataCloudUsers.forceInsert(u)

42+            }
 1
  • Scala的Akka编程中代码保持线程安全的重要性

    Master亮哥 @Liangliang  21 minutes ago

    这里如果是多线程的话,db还没成功,可能程序就返回Future.successful了。所以db.run{}.onComplete里返回successful


其实这样写在多线程环境中不能同步,用onComplete()方法做一个完美连接,就能保持同步。我现在在db.run后面没有用这个方法而直接返回了Future.successful(u.username),这样确实不合理,要保持连贯性,或者用flatMap也可以。


顺便了解了一下


new scala.collection.mutable.LinkedHashMap[String, Any]() with scala.collection.mutable.SynchronizedMap[String, Any]

在scala中实现SynchronizedMap就可以实现同步,或者concurrent.Map trait也可以.

cocurrentHashMap引入了分段锁的概念,不是锁整个HashMap,效率极大提高.


syncronized关键字也是一种方式:someMap.synchronized { someMap += ("someKey", "anyValue") }


http://www.scala-lang.org/docu/files/collections-api/collections_11.html


http://stackoverflow.com/questions/7952553/is-scalas-pattern-matching-regex-thread-safe


正则表达式由于继承类的关系,有些线程安全,有些则不是.scala.util.matching.Regex依赖于java.util.regex.Pattern,是线程安全的,但scala.util.matching.Regex.Match和scala.util.matching.Regex.MatchIterator不是线程安全的,scala.util.matching.Regex.MatchData是上述两个类的一部分,所以也找不到线程安全的实例.

因此在多线程环境中正则表达式匹配最好用scala.util.matching.Regex实现.


查了半天还是没查到match关键字和map是否线程安全,网上说的map是Map集合,不是map方法,可能需要查看一下底层实现.


后来经梁兄指导,每个消息都是独立的,内部肯定都会线程安全.


向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI