草庐IT

nio-thread

全部标签

具有多线程的 Java NIO SocketChannel.read()

我正在使用带有一个选择线程和多个工作线程(用于执行真正的读/写)的JavaNIO实现一个简单的文件服务器。代码的主要部分如下所示:while(true){intnum=selector.select();if(num>0){Iteratorkeys=selector.selectedKeys().iterator();finalSelectionKeykey=keys.next();keys.remove();if(key.isValid()){if(key.isAcceptable()){accept(key);}elseif(key.isReadable()){performRea

java - Fast NIO,Java 异步 HTTP 服务器

关闭。这个问题不满足StackOverflowguidelines.它目前不接受答案。想改善这个问题吗?更新问题,使其成为on-topic对于堆栈溢出。7年前关闭。Improvethisquestion关注thisquestion实际上,我也正处于为我的一个项目寻找合适的HTTP容器的阶段。我查看了几个容器,但我仍然不确定哪一个最适合高负载AJAX请求。ApacheMina看起来很有前途,但也相对复杂。名为AsyncWeb的异步Web服务器实现似乎已与Mina合并,但我还找不到它的任何生产版本。在另一个问题中,我推荐了SimpleHTTP我非常喜欢的服务器,因为它...非常简单、清晰和

java - 使用 java.nio.file.Paths 接口(interface)时缺少方案 (IllegalArgumentException)

这是一个非常简单的Java问题。我在linux系统上使用Java8和eclipsekepler。我一直在尝试NIO.2。我的代码是:packagelucasTest;importjava.io.IOException;importjava.net.URI;importjava.net.URISyntaxException;importjava.nio.file.*;publicclassLucas{publicstaticvoidmain(String[]args)throwsURISyntaxException{URIu=newURI("./Lucas.java");Pathp=Pa

java - 替代 Thread.suspend() 和 .resume()

我有一大段代码不是循环,只是执行一次但需要一些时间的命令列表。我需要它根据不断变化的boolean值随时暂停或终止它。我可以使用不同的线程来挂起、恢复和停止此代码,但这些方法已被弃用,因此我想避免使用它们。我可以检查每一行代码之间的boolean值,但我希望有一个更优雅的解决方案。有什么好的方法吗? 最佳答案 Icouldcheckthebooleanbetweeneverylineofcode,butIamhopingforamoreelegantsolution.Isthereagoodwaytodothis?很遗憾,没有。要替

java - GWT、Google App Engine、TimerTask 或 ServiceImpl 中的 Thread 抛出异常

我正在使用GWT和GoogleAppEngine。我有一系列记录,我想每30分钟更新一次。在ServiceImpl中,我有以下代码:newTimer().schedule(newTimerTask(){@Overridepublicvoidrun(){try{Thread.sleep(30000);}catch(InterruptedExceptione){e.printStackTrace();}result=updateFeeds();}},30000,Long.MAX_VALUE);当我运行应用程序时,当我得到:com.google.gwt.user.server.rpc.Une

java - 多 :Threading - Is this the right approach?

专家-在以下情况下我需要一些建议。我有一个包含任务列表的配置文件。每个任务可以有零个、一个或多个依赖项。我想并行执行这些任务[现在它们正在按顺序执行]想法是有一个主程序来读取配置文件并加载所有任务。读取单个任务并将其交给将执行任务并在Future中返回结果的执行程序[callable]。当任务被提交给执行者(线程)时,它将监视其依赖项是否首先完成并执行自己的任务。这是正确的方法吗?使用Java1.5功能还有其他更好的方法吗? 最佳答案 听起来不错,但要注意线程饥饿死锁。基本上,不要使用有界线程池。这里有一个例子可以说明这个问题。ht

java - 从多个线程调用时 Thread.sleep() 如何工作

sleep()是Thread类的静态方法。从多个线程调用时它是如何工作的。以及它如何确定当前的执行线程。?或者可能是一个更通用的问题是如何从不同的线程调用静态方法?不会有任何并发​​问题吗? 最佳答案 howdoesitfigureoutthecurrentthreadofexecution?没必要。它只是调用操作系统,操作系统总是让调用它的线程hibernate。 关于java-从多个线程调用时Thread.sleep()如何工作,我们在StackOverflow上找到一个类似的问题:

java - ThreadLocal 与 Tomcat NIO Connector 一起使用是否安全

这只是在我的负载测试期间测试TomcatNIO连接器时想到的。我还使用了ThreadLocal,我还使用了Spring,我知道它在几个地方也使用了它。由于NIO连接器没有每个连接一个线程,我担心如果ThreadLocal对象在被清理之前与另一个线程共享,可能会导致很难找到错误。但是,我认为这不是问题,因为它不是我能找到的书面警告,我也没有找到任何其他关于此的警告帖子。我假设NIO连接器对服务于实际请求的线程没有影响。在我做出这个假设之前,我希望找到一些具体的证据。 最佳答案 只有熟悉Tomcat代码的人才能给你一个具体的答案,但我会

Java - 主方法中的 Thread.sleep

我正在审查Java代码,它本质上是一个定期移动/读取/解析一些文件并将数据输出到数据库的重复过程。重复部分(大致)如下完成:publicclassCollectorMain{publicstaticbooleansignalRecieved=false;publicstaticvoidmain(String[]args){Runtime.getRuntime().addShutdownHook(newThread(){publicvoidrun(){shutdown();}});while(!signalRecieved){Collector.execute();try{Thread.

java - 并行化 : What causes Java threads to block other than synchronization & I/O?

简短版本在标题中。长版:我正在研究一个使用Java进行科学优化的程序。程序的工作负载可以分为并行和串行阶段——并行阶段意味着正在执行高度并行化的工作。为了加速程序(它运行数小时/数天),我创建了多个线程,这些线程的数量等于我正在使用的机器上的CPU核心数量——通常是4或8个——并在它们之间分配工作。然后我启动这些线程并加入()它们,然后再进入串行阶段。到目前为止一切顺利。困扰我的是并行阶段的CPU利用率和加速比“理论最大值”还差得很远——例如如果我有4个内核,我希望看到350-400%的“利用率”(如top所报告),但它在180到310之间反弹。仅使用一个线程,我获得100%的CPU利