我被指派处理多线程 Java 服务器的一些性能和随机崩溃问题。尽管线程和线程安全对我来说并不是真正的新主题,但我发现设计一个新的多线程应用程序的难度可能只有尝试调整一些遗留代码的一半。我浏览了一些知名书籍以寻找答案,但奇怪的是,只要我阅读它并分析提供的示例,一切似乎都很清楚。然而,当我看到我应该处理的代码时,我对任何事情都不确定了!一定是理论知识太多,实际经验太少之类的。
无论如何,回到主题,当我在做一些在线研究时,我遇到了 this piece of code .一直困扰我的问题是:在没有同步的情况下从两个单独的线程调用套接字上的 getInputStream() 和 getOutputStream() 真的安全吗?或者我现在对整个过程有点过于偏执了线程安全问题?猜猜这就是连续第 5 本书告诉您并发可能出错的情况。
附言。抱歉,如果问题有点冗长或者太“菜鸟”,请放轻松 - 这是我在这里的第一篇文章。
编辑: 澄清一下,我知道套接字在全双工模式下工作,同时使用它们的输入和输出流是安全的。当您在主线程中获取这些引用然后用它们初始化线程对象时,我觉得这很好,但是在两个不同的线程中获取这些流是否也安全?
@rsp:
所以我检查了 Sun 的代码,PlainSocketImpl 确实在这两个方法上同步,正如您所说。但是,Socket 没有。 getInputStream() 和 getOutputStream() 几乎只是 SocketImpl 的包装器,所以可能并发问题不会导致整个服务器爆炸。尽管如此,由于时机不巧,事情似乎可能出错(例如,当该方法已经检查了错误条件时,其他线程关闭了套接字)。
正如您所指出的,从代码结构的角度来看,为每个线程提供流引用而不是整个套接字是个好主意。如果不是因为每个线程也使用套接字的 close() 方法(例如,当套接字收到“关闭”命令时),我可能已经重组了我正在处理的代码。据我所知,这些线程的主要目的是将消息排队以供发送或处理,所以这可能违反了单一责任原则,这些线程不应该关闭套接字(与 Separated Modem Interface 比较) ?但如果我继续分析代码太久,就会发现设计通常存在缺陷,整个事情都需要重写。即使管理层愿意付出代价,认真重构遗留代码,没有任何单元测试,并处理难以调试的并发问题,也可能弊大于利。不是吗?
最佳答案
套接字的输入流和输出流代表两个独立的数据流或 channel 。在它们之间不同步的线程中使用两个流是完美的保存。套接字流本身将阻止读取和写入空缓冲区或满缓冲区。
编辑:来自 Sun 的套接字实现类确实同步了 getInputStream() 和 getOutputStream() 方法,然后从不同的线程调用应该没关系。然而,我同意你的观点,从代码结构的角度来看,将流传递给使用它们的线程可能更有意义(例如,依赖注入(inject)有助于测试。)
关于java - 套接字输入和输出的独立线程,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/1748808/
为了将Cucumber用于命令行脚本,我按照提供的说明安装了arubagem。它在我的Gemfile中,我可以验证是否安装了正确的版本并且我已经包含了require'aruba/cucumber'在'features/env.rb'中为了确保它能正常工作,我写了以下场景:@announceScenario:Testingcucumber/arubaGivenablankslateThentheoutputfrom"ls-la"shouldcontain"drw"假设事情应该失败。它确实失败了,但失败的原因是错误的:@announceScenario:Testingcucumber/ar
我正在使用puppet为ruby程序提供一组常量。我需要提供一组主机名,我的程序将对其进行迭代。在我之前使用的bash脚本中,我只是将它作为一个puppet变量hosts=>"host1,host2"我将其提供给bash脚本作为HOSTS=显然这对ruby不太适用——我需要它的格式hosts=["host1","host2"]自从phosts和putsmy_array.inspect提供输出["host1","host2"]我希望使用其中之一。不幸的是,我终其一生都无法弄清楚如何让它发挥作用。我尝试了以下各项:我发现某处他们指出我需要在函数调用前放置“function_”……这
我有一个在Linux服务器上运行的ruby脚本。它不使用rails或任何东西。它基本上是一个命令行ruby脚本,可以像这样传递参数:./ruby_script.rbarg1arg2如何将参数抽象到配置文件(例如yaml文件或其他文件)中?您能否举例说明如何做到这一点?提前谢谢你。 最佳答案 首先,您可以运行一个写入YAML配置文件的独立脚本:require"yaml"File.write("path_to_yaml_file",[arg1,arg2].to_yaml)然后,在您的应用中阅读它:require"yaml"arg
我真的很习惯使用Ruby编写以下代码:my_hash={}my_hash['test']=1Java中对应的数据结构是什么? 最佳答案 HashMapmap=newHashMap();map.put("test",1);我假设? 关于java-等价于Java中的RubyHash,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/questions/22737685/
这是一道面试题,我没有答对,但还是很好奇怎么解。你有N个人的大家庭,分别是1,2,3,...,N岁。你想给你的大家庭拍张照片。所有的家庭成员都排成一排。“我是家里的friend,建议家庭成员安排如下:”1岁的家庭成员坐在这一排的最左边。每两个坐在一起的家庭成员的年龄相差不得超过2岁。输入:整数N,1≤N≤55。输出:摄影师可以拍摄的照片数量。示例->输入:4,输出:4符合条件的数组:[1,2,3,4][1,2,4,3][1,3,2,4][1,3,4,2]另一个例子:输入:5输出:6符合条件的数组:[1,2,3,4,5][1,2,3,5,4][1,2,4,3,5][1,2,4,5,3][
我收到这个错误:RuntimeError(自动加载常量Apps时检测到循环依赖当我使用多线程时。下面是我的代码。为什么会这样?我尝试多线程的原因是因为我正在编写一个HTML抓取应用程序。对Nokogiri::HTML(open())的调用是一个同步阻塞调用,需要1秒才能返回,我有100,000多个页面要访问,所以我试图运行多个线程来解决这个问题。有更好的方法吗?classToolsController0)app.website=array.join(',')putsapp.websiteelseapp.website="NONE"endapp.saveapps=Apps.order("
我正在尝试使用boilerpipe来自JRuby。我看过guide从JRuby调用Java,并成功地将它与另一个Java包一起使用,但无法弄清楚为什么同样的东西不能用于boilerpipe。我正在尝试基本上从JRuby中执行与此Java等效的操作:URLurl=newURL("http://www.example.com/some-location/index.html");Stringtext=ArticleExtractor.INSTANCE.getText(url);在JRuby中试过这个:require'java'url=java.net.URL.new("http://www
我只想对我一直在思考的这个问题有其他意见,例如我有classuser_controller和classuserclassUserattr_accessor:name,:usernameendclassUserController//dosomethingaboutanythingaboutusersend问题是我的User类中是否应该有逻辑user=User.newuser.do_something(user1)oritshouldbeuser_controller=UserController.newuser_controller.do_something(user1,user2)我
我想使用spawn(针对多个并发子进程)在Ruby中执行一个外部进程,并将标准输出或标准错误收集到一个字符串中,其方式类似于使用Python的子进程Popen.communicate()可以完成的操作。我尝试将:out/:err重定向到一个新的StringIO对象,但这会生成一个ArgumentError,并且临时重新定义$stdxxx会混淆子进程的输出。 最佳答案 如果你不喜欢popen,这是我的方法:r,w=IO.pipepid=Process.spawn(command,:out=>w,:err=>[:child,:out])
什么是ruby的rack或python的Java的wsgi?还有一个路由库。 最佳答案 来自Python标准PEP333:Bycontrast,althoughJavahasjustasmanywebapplicationframeworksavailable,Java's"servlet"APImakesitpossibleforapplicationswrittenwithanyJavawebapplicationframeworktoruninanywebserverthatsupportstheservletAPI.ht