Java并发代码改进思路
是通过优化并发代码来提高程序的性能和可靠性。以下是一些改进思路：
- 使用线程池：线程池可以管理线程的生命周期，避免频繁创建和销毁线程的开销。可以使用Java提供的Executor框架来创建线程池，例如ThreadPoolExecutor类。推荐的腾讯云相关产品是云服务器CVM，产品介绍链接地址：https://cloud.tencent.com/product/cvm
- 使用同步机制：使用synchronized关键字或者Lock接口来保证多个线程对共享资源的互斥访问，避免数据竞争和线程安全问题。可以使用Java提供的并发包中的ReentrantLock类或者synchronized关键字来实现同步。
- 使用并发集合：Java提供了一些并发安全的集合类，例如ConcurrentHashMap和ConcurrentLinkedQueue，它们可以在多线程环境下安全地进行操作。这些集合类可以提高并发性能并减少线程间的竞争。
- 减少锁粒度：如果可能的话，可以将锁的粒度降低，减少锁竞争的范围。例如，可以使用细粒度的锁来代替粗粒度的锁，或者使用无锁的数据结构来避免锁竞争。
- 使用原子类：Java提供了一些原子类，例如AtomicInteger和AtomicLong，它们可以在多线程环境下进行原子操作，避免了锁的开销和竞争。
- 使用并发工具类：Java提供了一些并发工具类，例如CountDownLatch和CyclicBarrier，它们可以帮助线程之间进行同步和协作。
- 使用并行流：Java 8引入了并行流的概念，可以使用Stream API来进行并行计算，充分利用多核处理器的优势。
- 使用无锁算法：无锁算法是一种无需使用锁的并发编程技术，可以提高并发性能。例如，可以使用CAS（Compare and Swap）操作来实现无锁算法。
- 使用异步编程：使用异步编程模型可以提高程序的并发性能。可以使用Java提供的CompletableFuture类或者使用第三方库，例如RxJava来实现异步编程。
- 使用并发调试工具：Java提供了一些并发调试工具，例如jstack和jconsole，可以帮助定位并发问题和性能瓶颈。
以上是改进Java并发代码的一些思路和方法，根据具体的应用场景和需求，可以选择适合的方法来优化并发代码。
相关·内容
我使用的是带有32 32执行程序的flink mysql连接器，有32个插槽的16 16vCPU。如果我运行一个具有并行性32 (作业并行性224)的作业，它使用10个MySQL表执行时态查找联接，那么在2-3次成功运行之后，它就会开始失败。
org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandle
浏览 17提问于2022-01-17得票数 0
使用WSO2IS 5.1.0 (我相信任何版本都会有此问题)，我们在传入的并发身份验证请求方面存在问题。
可以在两种情况下(正如我们看到的那样)发生相同的身份验证请求：
首先:当用户尚未使用进行身份验证时，登录表单的多个帖子。当用户不够耐心，双击登录按钮(或者垃圾邮件登录提交按钮，有些用户会这样做)时，就会发生这种情况。使用自定义登录页面，我们对UI有一定的控制，我们可以防止用户发布多个帖子(禁用submit上的submit按钮)。
其次(这是我们看到真正问题的地方)：当用户已经通过身份验证时，接收多个身份验证请求将向retry.do页面发送带有错误消息的用户。
FINEST|6940/0|S
浏览 0提问于2016-10-18得票数 1
回答已采纳
1回答
我在我的安卓应用程序中包括了AdColony，现在我正在尝试用proguard导出我的应用程序。我找到了AdColony 和的配置。我试图将它们单独和一起包含到proguard.cfg中，但是它不起作用。
组合：
-dontwarn android.webkit.**
# another config
-dontwarn com.jirbo.adcolony.**
-keep class com.jirbo.adcolony.**{*;}
普罗维特说：
Proguard returned with error code 1. See console
Proguard Error 1
Outp
浏览 4提问于2015-07-16得票数 2
回答已采纳
在我的项目中，main方法中的代码类似于
jsEngine.eval(new FileReader(scrFile1));
jsEngine.eval(new FileReader(scrFile2));
我需要将这些文件作为线程传递。这个问题有什么解决办法吗？？
浏览 0提问于2012-06-13得票数 1
目前，我们有一个spring-boot (1.2.1.RELEASE)应用程序，spring-security运行成功。
我们已经使用以下配置成功地实现了并发控制
@Configuration
@EnableGlobalMethodSecurity(securedEnabled = true)
public class SecurityConfig {
@Order(SecurityProperties.ACCESS_OVERRIDE_ORDER)
@Configuration
protected static class ApplicationSecurity ex
浏览 0提问于2015-02-19得票数 2
我们必须实现一个垂直的对象库(例如静态文本)，在屏幕中心有固定的焦点。焦点将停留在一个点，项目将上下滚动。列表将从屏幕的中心开始。问题：
可以用ListView来完成吗？如何？还是我必须扩展图片库对象并进行定向工作？
浏览 0提问于2011-03-28得票数 4
回答已采纳
可能重复：
如果某些代码是线程安全的，我正在寻找单元测试的最佳方法。
我使用NUnit和Moq作为单元测试框架。
浏览 1提问于2011-03-15得票数 1
我在hadoop集群中得到了LeaseExpiredException -
/var/log/hadoop-hdfs/hadoop-hdfs-namenode-ip-172-30-2-148.log 尾部-f
2016-09-21 11:54:14,533 INFO BlockStateChange (IPC服务器处理程序10 on 8020)：块* InvalidateBlocks:添加blk_1073747501_6677到172.30.2.189:50010 2016-09-21 11:54:14 534 INFO org.apache.hadoop.ipc.Server (IPC服务
浏览 12提问于2016-09-21得票数 4
2回答
直到Java 8，我们已经看到并行GC作为默认垃圾收集器，但是最近发布的Java (Java9)使用G1 GC作为默认垃圾收集器。
为什么Java已经转移到G1 GC了？性能有什么改善吗？
浏览 4提问于2017-09-23得票数 11
回答已采纳
2回答
我还处于用Android ( Java)开发游戏的早期阶段，在我的游戏循环中添加/删除对象时遇到了并发问题。
这个应用程序有两个独立的片段，一个是控制器，另一个是显示游戏循环的SurfaceView。控制器有一些按钮，可以提示创建对象，然后将这些对象添加到游戏循环中。并发问题看起来是随机出现的，但大多数情况下，当一个对象从存储它的ArrayList中删除，另一个对象被添加到该对象中进行绘制时。
在运行过程中，崩溃不是均匀发生的，也不是在相同的点发生的，所以我在这里感到不知所措。我已经将我所有的For-each循环切换到ListIterator的添加/删除调用，以为这样可以避免并发问题，但事实证
浏览 4提问于2016-12-28得票数 1
1回答
我有一个应用程序，它通过java应用程序每1-2分钟记录多达8000个设备的状态，并将设备in、时间和状态存储在数据库中的一个表中。
这个应用程序的下一个组件是一个PHP界面，它显示这些设备的最新状态(这些设备分配给登录的用户，可能有最多500个并发用户，即每个用户查看16个设备，但可能超过50-100个用户的平均负载)。该应用程序还将打印设备一段时间内的状态报告。
我考虑在java应用程序中使用memcached来存储每个deviceid的最新状态，然后让php应用程序只访问memcached来填充显示。有关以前状态的报告仍将从数据库中删除，因为它们不经常运行。
由于memcached的性能
浏览 0提问于2010-11-02得票数 0
回答已采纳
我正在研究ScalaDoc工具的一些特性，它允许库编写人员链接到第三方工具(如JavaDoc )创建的文档。
我的想法是有一些( XML )配置，它指定哪个包前缀属于哪个供应商，以及如何从类名创建一个有效的URL，作为正则表达式和格式字符串存储在XML中。
如果给定的配置不支持包名，我只需要一个公共方法getLink(entity: String): Option[String]，它可以返回Some(validURL)或None。如果它改进了代码，其他的一切都可以随我的意愿进行更改。
请考虑以下代码：
object ExternalReferences2 {
import java.uti
浏览 0提问于2011-08-19得票数 5
我已经5年没有使用Java了，但我又回到了就业市场，现在的Java职位似乎比C/C++还多。有什么资源可以迅速恢复速度吗？我开发的最后一个Java是1.3。
对于springs和struts这样的java技术，有什么好的资源呢？
浏览 0提问于2011-04-04得票数 7
回答已采纳
4回答
我有一个大型的单线程java程序，它需要很长时间才能输出结果。我正在考虑使它并发，但这让我想知道:并发对我的应用程序有帮助吗？真的会有帮助吗？
因此，我在此要求：
我应该(在我的程序中)寻找哪些属性来表示多线程/并发是可行的？
这有什么规则吗？
浏览 4提问于2014-11-12得票数 0
回答已采纳
2回答
抄写和比较-然后交换的区别？
、、、、
我正在学习(java.util.concurrent)和所使用的底层技术。我无意中发现了抄写、比较和交换。
我不太明白这两者有什么区别。或者两者都用在一起了？
浏览 3提问于2020-06-23得票数 1
回答已采纳
我想用jmeter生成给kafka的消息。我在下面找到了与jmeter集成的建议：Develop Apache Kafka producer and load testing using JMeter 我还发现了https://github.com/corunet/kloadgen，它集成了confluent模式，可以让你向kafka主题编写avro消息。 我正在尝试使用jmeter将以下模式消息写入kafka： {"type":"record","name":"TestAvro","namespace":
浏览 22提问于2020-06-23得票数 0
1回答
有没有办法在SonarQube的分析和仪表板中包含Java编译器的警告？
我在Jenkins的名下通过Maven运行SonarQube。
浏览 0提问于2013-08-22得票数 2
2回答
问题-
我正在运行AWS EMR中的一个查询。它失败了，抛出了异常-
java.io.FileNotFoundException: File s3://xxx/yyy/internal_test_automation/2016/09/17/17156/data/feed/commerce_feed_redshift_dedup/.hive-staging_hive_2016-09-17_10-24-20_998_2833938482542362802-639 does not exist.
我在下面提到了这个问题的所有相关信息。请查收。
查询-
INSERT OVERWRITE TABLE b
浏览 6提问于2016-09-17得票数 9
回答已采纳
import javax.swing.JList.*;
import java.awt.event.*;
import java.util.ArrayList;
import java.awt.*;
import javax.swing.*;
public class test {
static JFrame frame=new JFrame();
//return
static DefaultListModel lt=new DefaultListModel();
static J
浏览 10提问于2022-06-04得票数 0
1回答
我不知道在Eclipse中从哪里开始。
我想创建一个布局与一些文本框(用户名/密码)和一个按钮“发送”
当用户填写其用户名和密码时，必须使用其用户名/密码安装无线配置文件(TTLS/MSCHAPV2)。
到目前为止，我得到了带有onclick功能的按钮。
mainactivity.java。(public void installprofile(View view) { // Do something in response to button
现在我必须放置wifi配置代码。我如何让代码知道他需要哪个用户名/密码来安装配置文件？
它必须从文本框中获取用户名/密码。
向Kevi
浏览 0提问于2013-03-29得票数 0
4回答
背景
我正在设计我的软件，这样我就可以很容易地执行单元测试。我有一个IClock接口，除其他方法外，还有IClock#wait(TimeUnit timeUnit, long duration)。此方法将在timeUnit持续时间内停止当前线程(即1秒)。
IClock接口有两个实现：
SimulatedClock：有手动增加时钟存储时间的方法
RealClock：引用System.currentTimeMillis()自动增加时间
这是IClock#wait(...)的默认方法
/**
* Locks current thread for specified tim
浏览 1提问于2018-08-13得票数 4
我过去曾使用Excel在一个月内获取1000多只股票证券的每日价格数据，这是一种非常缓慢的体验(在某些情况下，等待1小时)，因为我使用彭博Excel插件打了大量电话。
我一直在想，如果我使用Python或Java来从Bloomberg的API中提取数据，那么是否会有很大的性能改进来完成同样的任务。
在我开始尝试实现Python或Java解决方案之前，我想从那些对Excel和编程语言都有经验的人那里了解。
浏览 2提问于2017-11-15得票数 0
回答已采纳
1回答
如何对WicketStuff的Spinner配置方法的java.util.Properties‘onIncrement、onDecrement、afterUpdate或onStop属性进行函数调用？我尝试了以下方法，但是函数没有被调用：
TextField<String> textField = new TextField<String>("textField ", new Model<String>("0"));
textField.add(new Spinner() {
@Override
protecte
浏览 2提问于2016-02-15得票数 0
通过在Java中使用VarHandle类，您可以实现对对象的原子操作，通过这些类，像AtomicReferenceArray这样的类可以对数组元素执行并发操作，而无需锁定(同步)整个数组结构，从而获得显著的性能增益。
其他同步和线程安全版本的集合没有实现这样的模型，有什么具体的原因吗？
例如，collection类中的所有同步工厂方法都返回相应集合的版本，该集合使用同步方法来锁定整个集合！
浏览 15提问于2021-12-25得票数 0
回答已采纳
我正在阅读有关ConcurrentHashMap的内容，并检查了它的密钥集的removeAll()实现。在当前的实现中，JAVA正在迭代整个键集数据结构，即使给定的集合只包含一个元素或没有元素。
实际执行
public final boolean removeAll(Collection<?> c) {
if (c == null) throw new NullPointerException();
boolean modified = false;
for (Iterator<E> it = iterator();
浏览 4提问于2017-04-24得票数 2
1回答
如何解决谷歌应用引擎延迟问题？
、、、、
我们的项目运行在Google标准环境中，自动缩放配置如下所示。在应用程序中启用了热身请求，我们正在使用Google服务。但是，在不同的场景中，我面临一个延迟问题。环境：Java 8，实例类型:用于自动标度的F4_1G配置：min-实例:2 max-并发-请求: 80分钟待定延迟: 6s max-未决延迟: 10s
我用JMeter进行了测试，配置为发送85异步请求，提升时间为10秒。从应用程序日志中，我可以注意到，应用程序引擎需要很长时间才能为request.Below服务，这是我遇到的问题
1.由于时间过长，大多数请求都失败了。在图1中，我们可以发现请求需要88.2秒。我知道AppEngin
浏览 5提问于2020-04-06得票数 0
1回答
我想在页面中构建链接的select元素，所以我使用json来保存数据。
数据：
var data=[{"name":"Java Language","value":"java","options":[
{"name":"Thinking In Java","value":"tinjava"},
{"name":"Thinking in Pattern","v
浏览 2提问于2011-06-17得票数 0
1回答
我结合使用标准java类MavenProject和com.jcabi.aether.Aether java API来确定给定POM的jar依赖关系集。默认情况下，不会通过API进行资源过滤，我还没有发现如何为依赖项调用Aether.resolve()，比如
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>${my-junit.version}</version>
<scope
浏览 6提问于2013-07-05得票数 0
如何将用户输入(Edittext)传递给服务器上的php脚本？我正试着让这件事通过wamp先在当地运作。我允许wamp conf文件中的所有连接，并为我在www文件夹中使用的文件夹创建了一个别名。我的代码如下：
public class GetItemsActivity extends FoodSearchActivity {
public void postData(View v) {
//get food from edit text box
String food = txtFoodSearch.getText().toString();
System.out
浏览 3提问于2014-02-07得票数 0
回答已采纳
错误"java.util.ConcurrentModificationException“有时会出现，当我测试三次以上的时候错误就会出现，我不明白为什么它总是指向"Word w= iter.next ();”，为什么它并不总是显示错误。
//LoadFile.java
@Override
public void run() {
BufferedReader reader = null;
try {
reader = new BufferedReader(new InputStreamReader(
浏览 3提问于2015-03-23得票数 0
我正在制作一个web应用程序，我想在缓存中存储图像。下一次我不想从网络上获取图片。我如何使用java实现，使用WeakHashmap或Hashmap。
浏览 2提问于2010-04-22得票数 0
1回答
我有一个xPage，它使用Server side Javascript beforePageLoad调用来填充来自远程JSON REST服务的一些字段。
获取此错误.....调用"accessClassInPackage.sun.net.www.protocol.https")类‘openConnection’的方法‘java.net.URL()’时出错，权限被拒绝("java.lang.RuntimePermission“java
这在web浏览器中有效。是否有需要更改的客户端设置，或者有没有更好的方法来更改，这样我也可以在Notes XPiNC环境中使用它？
代码如
浏览 21提问于2020-06-03得票数 0
我们有需要el-api 2.2的primes faces，以及似乎使用el-api 1.0的tiles 2.2.2，所以tiles不起作用。下面是堆栈跟踪。似乎带有el 2.2的tiles可以在tomcat7中工作，但在WAS 7中不能工作。我们正在使用与PARENT_LAST类加载器的共享库加载prime faces和el-api，el-impl2.2。
Caused by: java.lang.VerifyError: JVMVRFY013 class loading constraint violated; class=freemarker/ext/jsp/FreeMarkerPageC
浏览 8提问于2013-06-04得票数 0
3回答
我计划用Java做一个项目，在这个项目中，我想把顺序的Java代码转换成并发的Java代码，并测量效率.Any建议，关于哪个免费源代码的java应用程序最适合我的project.Any其他建议是如何进行的？
提前感谢契德
浏览 2提问于2010-02-25得票数 1
1回答
受多线程影响的算法的运行时间是如何指定的？
例如，一个CompareAndSet循环可能永远不会被满足(如果你非常非常不幸)
AtomicReference<ContainerOfItems> oldContainer;
void AddItem(Item aItem)
{
ContainerOfItems newContainer;
do
{
newContainer = null;
newContainer = new ContainerOfItems();
newContainer.CopyConte
浏览 2提问于2012-08-21得票数 1
回答已采纳
继续到
我正在使用注解
@Cache(usage = CacheConcurrencyStrategy.READ_ONLY, region = "userType"
在我的实体中：
import java.io.Serializable;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistenc
浏览 5提问于2016-07-29得票数 0
回答已采纳
tomcat是一个著名的Apache许可的web服务器。有许多稳定的版本。我一直使用的是Tomcat 8，最近发布了一个新的原生版本，引用自Apache网站。
Apache自豪地宣布了Tomcat原住民1.2.24的发布。
有人能解释一下Tomcat原住民和Tomcat之间的区别吗？此外，当我们将软件框架称为本地框架时，例如，我们真正的意思是什么？
浏览 2提问于2020-05-12得票数 1
我正在尝试为一个discord.py机器人创建一个!mute命令。我希望它的格式是这样：!mute @user 10s。s是针对秒的。我还希望它能够阅读几分钟的m，几个小时的h和几天的d。如果可能的话，甚至可以叫!mute @user 1d 3h 3s。这是我现在拥有的代码。 @client.command()
@commands.has_permissions(kick_members=True)
async def mute(ctx, member: discord.Member, mute_time : int):
guild = ctx.guild
for role
浏览 13提问于2020-06-18得票数 0
我正在尝试将一个能正常工作的Mongo Shell查询翻译成java，但是我好像撞上了一堵墙。我使用的是mongo-java-driver:3.9.1。shell查询如下所示： db.getCollection('xyz').find({source_id: ObjectId("abc"), timestamp: {
$gte : ISODate("2019-04-05 18:24:00.000Z"),
$lt: ISODate("2019-04-05 18:30:00.000Z")
}
}) 该查询
浏览 15提问于2019-05-24得票数 0
回答已采纳
我是一个非常有经验的Java程序员，我所有的时间都在使用Java1.4和更早的版本。我在哪里可以找到一个快速参考，它将为我提供关于Java5中的新功能以及稍后的快速参考中所需的所有信息？
浏览 0提问于2008-09-15得票数 5
这是我的错误信息：
Unexpected error while performing partial evaluation:
Class = [org/apache/log4j/chainsaw/Main]
Method = [<init>()V]
Exception = [java.lang.IllegalArgumentException] (Can't find common super class of [java/lang/NoClassDefFoundError] (with 5 known super classes)
浏览 1提问于2015-11-10得票数 1
java -version
java版本"1.6.0_21“Java(TM) SE运行时环境(build 1.6.0_21-b07) Java HotSpot(TM) 64位服务器VM (build 17.0-b17，混合模式)
jvm配置：
-server -XX:+DoEscapeAnalysis -XX:+CMSParallelRemarkEnabled -XX:+UseBiasedLocking -XX:ParallelGCThreads=20 -XX:+UseLargePages -XX:+UseConcMarkSweepGC -XX:+UseParNewGC -X
浏览 3提问于2016-01-14得票数 0
2回答
目前，我正在进行一个Java项目，我需要使用Java运行JavaScript Mongo查询。我发现我可以使用db.eval()来做类似的事情。问题是我有以下针对Mongo的JavaScript查询，我不知道如何将整个脚本传递给db.eval()方法。
var red = function(doc, out) {
out.count_order++;
out.sum_qty += doc.quantity;
out.sum_base_price += doc.extendedprice;
out.sum_disc_price += doc.extendedprice * (1 - doc.di
浏览 1提问于2013-04-26得票数 0
我已经看到很多文章指出，不建议使用Java并发创建线程。为什么是这样，在我的代码中生成第二个线程的正确方法是什么？如果可能的话，我更愿意保留核心的Java。
浏览 6提问于2013-10-22得票数 2
回答已采纳
在Java语言的背景下，在多个线程之间拆分多个任务的问题可以很容易地使用ExecutorService并通过该接口提交任务。你会说同样的方法在Scala世界中是有意义的吗？如果有，有没有Scala版本的API？
如果没有，你会推荐什么方法？演员似乎有点过头了，因为我认为他们主要用于线程通信……
浏览 0提问于2013-04-24得票数 4
回答已采纳
1回答
要查找和替换的正则表达式
、、、
我正在寻找一个正则表达式，以便在string.empty的VS2010解决方案文件中查找并替换为string.IsNullOrEmpty
从ex if (strText != string.Empty)到string.IsNullOrEmpty(strText)
浏览 0提问于2012-12-13得票数 0
回答已采纳
所以我基本上有一个名字的结构体，它必须是一元的，还有一个ID。我想它可以是这样的。
typedef struct {
char *name;
unsigned int id;
} person;
现在，我将按照给定的开始编写一个函数：
person *readData();
结构和名称都必须是非常简单的，我想用malloc函数来完成这一任务。对于所有的人，也应该有一个数组，让我们命名它为"people1000“。
下面是我对上述功能的尝试，主要功能如下：
int count = 0;
person *readData() {
int i, len;
char puff
浏览 3提问于2014-01-09得票数 1
回答已采纳
3回答
看起来我好像错过了什么。
当使用Jython在Java中运行我的Python代码时，会生成Java字节码文件(test.py -> test@py.class)。
我能用java直接运行这些类吗？
换句话说，我想这样做：
$ java test@py [additional cp args]
工作。
其目的是:编写Python代码，而不必提供源代码。
浏览 1提问于2010-04-06得票数 10
我们正在使用AVAssetDownloadTask应用程序接口集在我们的应用程序中构建离线公平播放功能。我们可以成功地下载内容，但是我们注意到在播放下载的内容时，网络活动是对movpkg包中的boot.xml中呈现的m3u8播放列表的请求。
问题是加载那些需要cookies的m3u8播放列表，cookies被设置为1天后过期，这会导致cookies过期时播放失败。我的问题是，为什么播放下载的内容需要加载这些播放列表？它不是应该在没有网络的情况下播放下载的内容吗？
谢谢。
浏览 3提问于2020-11-28得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
云直播活动推荐
腾讯云开发者
