搜索[并发编程]结果-低调大师优秀个人博客

精选列表

搜索[并发编程]，共10000篇文章

IOS Socket编程

iphone的标准推荐CFNetwork C库编程.但是编程比较烦躁。在其它OS往往用类来封装的对Socket函数的处理。

2017-11-16

Socket通常也称做”套接字“，用于描述IP地址和端口，它就是网络通信过程中端点的抽象表示。Java在包java.net中提供了两个类Socket和ServerSocket，分别用来表示双向连接的客户端和服务端。 SocketServer类，服务器实现： public class SocketServer { ServerSocket sever; public SocketServer(int port){ try{ sever = new ServerSocket(port); }catch(IOException e){ e.printStackTrace(); } } public void beginListen(){ while(true){ try{ final Socket socket = sever.accept(); new Thread(new Runnable(){ public void run(){ BufferedReader in; try{ in = new BufferedReader(new InputStreamReader(socket.getInputStream(),"UTF-8")); PrintWriter out = new PrintWriter(socket.getOutputStream()); while (!socket.isClosed()){ String str; str = in.readLine(); out.println("Hello!world!! " + str); out.flush(); if (str == null || str.equals("end")) break; System.out.println(str); } socket.close(); }catch(IOException e){ e.printStackTrace(); } } }).start(); }catch(IOException e){ e.printStackTrace(); } } } } public class TestSocketServer { public static void main(String[] argvs){ SocketServer server = new SocketServer(12345); server.beginListen(); } } 客户端实现： public class SocketClientDemo extends Activity implements Runnable { private TextView tv_msg = null; private EditText ed_msg = null; private Button btn_send = null; private static final String HOST = "192.168.1.223"; private static final int PORT = 12345; private Socket socket = null; private BufferedReader in = null; private PrintWriter out = null; private String content = ""; /** Called when the activity is first created. */ @Override public void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.main); tv_msg = (TextView) findViewById(R.id.TextView); ed_msg = (EditText) findViewById(R.id.EditText01); btn_send = (Button) findViewById(R.id.Button01); try { socket = new Socket(HOST, PORT); in = new BufferedReader(new InputStreamReader(socket.getInputStream())); out = new PrintWriter(new BufferedWriter(new OutputStreamWriter( socket.getOutputStream())), true); } catch (IOException ex) { ex.printStackTrace(); ShowDialog("login exception" + ex.getMessage()); } btn_send.setOnClickListener(new Button.OnClickListener() { @Override public void onClick(View v) { // TODO Auto-generated method stub String msg = ed_msg.getText().toString(); if (socket.isConnected()) { if (!socket.isOutputShutdown()) { out.println(msg); } } } }); new Thread(SocketDemo.this).start(); } public void run() { try { while (true) { if (socket.isConnected()) { if (!socket.isInputShutdown()) { if ((content = in.readLine()) != null) { content += "\n"; Log.d("socket","socket:"+content); } else { } } } } } catch (Exception e) { e.printStackTrace(); } } } 注意在AndroidManifest.xml中加入对网络的访问权限 <uses-permission android:name="android.permission.INTERNET"></uses-permission> 本文转自xyz_lmn51CTO博客，原文链接：http://blog.51cto.com/xyzlmn/1230758，如需转载请自行联系原作者

2017-11-10

android 编程基础

应用程序基础 android 应用程序由java编程语言编写. android sdk工具会将android代码和数据以及资源文件编译成为一个android package,这是一个归档文件,名称以.apk

2017-10-11

Java编程初学者应该了解的编程框架

动力节点Java培训最新上线Java实验班，等你来测试自己适不适合学习Java编程哦！很多的Java初学者从前辈的口中和各种资料中经常会听到一个词：Java框架，那么什么是“Java框架”?

2019-06-23

JavaScript函数式编程之pointfree与声明式编程

更多相关内容见博客 github.com/zhuanyongxi… 函数式编程中的pointfree的意思就是“无参”或“无值”，pointfree style是一种编程范式，也作tacit programming

2018-07-23

Java并发包下锁学习第二篇Java并发基础框架-队列同步器介绍

Java并发包下锁学习第二篇队列同步器还记得在第一篇文章中，讲到的locks包下的类结果图吗？

2020-03-31

Java编程基础阶段笔记 day 07 面向对象编程（上）

面向对象编程笔记Notes 面向对象三条学习主线面向过程 VS 面向对象类和对象创建对象例子面向对象的内存分析类的属性：成员变量成员变量 VS 局部变量类的方法方法的重载可变个数形参

2019-08-04

Java并发集合详解：从HashMap到ConcurrentHashMap

这坑凡是写过并发的估计都踩过。

2026-08-09

HarmonyOS如何使用异步并发能力进行开发

一、并发概述并发是指在同一时间段内，能够处理多个任务的能力。为了提升应用的响应速度与帧率，以及防止耗时任务对主线程的干扰，HarmonyOS系统提供了异步并发和多线程并发两种处理策略。

2023-09-22

深入理解 Serverless 计算的并发度

接下来我们重点剖析下不同产品形态下并发的语义以及为什么这些流行的 Serverless 计算产品为什么采用并发度作为扩缩容的策略。什么是并发？

2023-07-20

大哥，这是并发不是并行，Are You Ok？

当谈论并发的时候一定要加个单位时间,也就是说单位时间内并发量是多少?离开了单位时间其实是没有意义的。俗话说,一心不能二用,这对计算机也一样,原则上一个CPU只能分配给一个进程,以便运行这个进程。

2023-02-08

解决跨海高并发崩溃难题？so easy

这使得短时间内对服务器的并发请求数激增，很容易导致服务器崩溃。我也是在了解这些后，才知道每年我参与秒杀活动失败的真正原因。什么是高并发了解高并发之前，我们要先知道并发数是什么？

2022-06-08

如何管理并发写入操作？带你快速上手

管理并发写入操作目录：事务隔离说明写入和读写操作并发写入事务的潜在锁死情况并发写入实例一、事务隔离说明 openGauss基于MVCC（多版本并发控制）并结合两阶段锁的方式进行事务管理，其特点是读写之间不阻塞

2022-03-21

如何快速调度 PTS 的百万并发能力

对于场景简单，要求测试并发量不高的情况下，JMeter 本地测试就能满足需求。

2022-01-18

Excelize 发布 2.4.1 版本，新增并发安全支持

BESSELY 公式计算引擎支持自定义名称引用，相关 issue #856 添加图表时支持设置不显示主要横纵坐标轴通过AddPivotTable创建数据透视表支持通过自定义名称动态引用数据源以下函数新增支持并发安全调用

2021-08-01

线程的安全性 - 并发基础篇

作者：汤圆个人博客：javalover.cc 前言官人们好啊，我是汤圆，今天给大家带来的是《线程的安全性 - 并发基础篇》，希望有所帮助，谢谢文章纯属原创，个人总结难免有差错，如果有，麻烦在评论区回复或后台私信

2021-04-25

微服务架构的高并发问题

1 准备环境 1.1 准备商品微服务和订单微服务其中商品微服务的findById()方法设置休眠2秒，用来模拟网络波动等情况： package com.sunxiaping.product.controller; import com.sunxiaping.product.domain.Product; import com.sunxiaping.product.service.ProductService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.web.bind.annotation.*; @RestController @RequestMapping(value = "/product") public class ProductController { @Autowired private ProductService productService; @Value("${server.port}") private String port; @Value("${spring.cloud.client.ip-address}") private String ip; @PostMapping(value = "/save") public String save(@RequestBody Product product) { productService.save(product); return "新增成功"; } @GetMapping(value = "/findById/{id}") public Product findById(@PathVariable(value = "id") Long id) { try { //休眠2秒，用来模拟网络波动等情况 Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } Product product = productService.findById(id); product.setProductName("访问的地址是：" + ip + ":" + port); return product; } } 设置订单微服务的Tomcat的最大线程数是10： server: port: 9002 # 微服务的端口号 tomcat: max-threads: 10 # 最大线程数是10 spring: application: name: service-order # 微服务的名称 datasource: url: jdbc:mysql://192.168.1.57:3306/test?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false&serverTimezone=GMT%2B8&allowPublicKeyRetrieval=true driver-class-name: com.mysql.cj.jdbc.Driver username: root password: 123456 jpa: generate-ddl: true show-sql: true open-in-view: true database: mysql jmx: unique-names: true # 配置Eureka eureka: instance: # 实例的名称 instance-id: service-order:9002 # 显示IP信息 prefer-ip-address: true lease-renewal-interval-in-seconds: 5 # 发送心跳续约间隔（默认30秒） lease-expiration-duration-in-seconds: 10 # Eureka Client发送心跳给Eureka Server端后，续约到期时间（默认90秒） client: healthcheck: enabled: true service-url: # Eureka Server的地址 # defaultZone: http://localhost:9000/eureka/ defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/ # Ribbon的重试机制 service-product: ribbon: # 修改ribbon的负载均衡策略服务名 - ribbon - NFLoadBalancerRuleClassName ：负载均衡策略 # NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule # 修改ribbon的负载均衡策略为权重策略 # Ribbon的重试机制参数 ConnectTimeout: 250 # Ribbon的连接超时时间 ReadTimeout: 1000 # Ribbon的数据读取超时时间 OkToRetryOnAllOperations: true # 是否对所有操作都进行重试 MaxAutoRetriesNextServer: 50 # 切换实例的重试次数 MaxAutoRetries: 1 # 对当前实例的重试次数 # 微服务info内容详细信息 info: app.name: xxx company.name: xxx build.artifactId: $project.artifactId$ build.version: $project.version$ # 开启日志debug logging: level: root: info 订单微服务中的SpringConfig.java package com.sunxiaping.order.config; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.web.client.RestTemplate; @Configuration public class SpringConfig { @Bean // @LoadBalanced public RestTemplate restTemplate() { return new RestTemplate(); } } 订单微服务的OrderController.java package com.sunxiaping.order.controller; import com.sunxiaping.order.domain.Product; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.client.RestTemplate; @RestController @RequestMapping(value = "/order") public class OrderController { @Autowired private RestTemplate restTemplate; /** * @param id * @return */ @GetMapping(value = "/buy/{id}") public Product buy(@PathVariable(value = "id") Long id) { Product product = restTemplate.getForObject("http://localhost:9001/product/findById/" + id, Product.class); return product; } @GetMapping(value = "/findOrder") public String findOrder() { return "商品查询到了"; } } 2 使用Jmeter测试接口使用JMeter性能测试工具以50个线程每个线程循环50次测试：http://localhost:9002/order/buy/1接口，然后通过浏览器调用http://localhost:9002/order/findOrder接口，发现特别慢。 3 系统负载过高存在的问题 3.1 问题分析在微服务架构中，我们将业务拆成一个个的服务，服务和服务之间可以相互调用，由于网络原因或者自身的原因，服务并不能保证100%可用，如果单个服务出现问题，调用这个服务就会出现网络延迟，此时如果有大量的网络请求涌入，会形成任务累计，导致服务瘫痪。换句话说，Tomcat等容器会以线程池的方式对所有的请求进行统一的管理，如果某个方法可能存着耗时问题，随着外面积压的请求越来越多，势必会造成系统的崩溃、瘫痪等。为了不影响其他接口的正常访问：对多个服务之间进行隔离。服务隔离的方式： :one:线程池隔离。 :two:信号量隔离（计数器，就是对某个方法进行设置阈值，如果超过了阈值，直接报错）。 4 线程池隔离的方式处理积压问题 4.1 在订单微服务中引入相关jar包的Maven坐标 <dependency> <groupId>com.netflix.hystrix</groupId> <artifactId>hystrix-metrics-event-stream</artifactId> <version>1.5.12</version> </dependency> <dependency> <groupId>com.netflix.hystrix</groupId> <artifactId>hystrix-javanica</artifactId> <version>1.5.12</version> </dependency> 4.2 配置线程池配置HystrixCommand接口的实现类，在实现类中可以对线程池进行配置： package com.sunxiaping.order.command; import com.netflix.hystrix.*; import com.sunxiaping.order.domain.Product; import org.springframework.web.client.RestTemplate; public class OrderCommand extends HystrixCommand<Product> { private RestTemplate restTemplate; private Long id; public OrderCommand(RestTemplate restTemplate, Long id) { super(setter()); this.restTemplate = restTemplate; this.id = id; } private static Setter setter() { // 服务分组 HystrixCommandGroupKey groupKey = HystrixCommandGroupKey.Factory.asKey("order_product"); // 服务标识 HystrixCommandKey commandKey = HystrixCommandKey.Factory.asKey("product"); // 线程池名称 HystrixThreadPoolKey threadPoolKey = HystrixThreadPoolKey.Factory.asKey("order_product_pool"); /** * 线程池配置 * withCoreSize : 线程池大小为10 * withKeepAliveTimeMinutes: 线程存活时间15秒 * withQueueSizeRejectionThreshold :队列等待的阈值为100,超过100执行拒绝策略 */ HystrixThreadPoolProperties.Setter threadPoolProperties = HystrixThreadPoolProperties.Setter().withCoreSize(50) .withKeepAliveTimeMinutes(15).withQueueSizeRejectionThreshold(100); // 命令属性配置Hystrix 开启超时 HystrixCommandProperties.Setter commandProperties = HystrixCommandProperties.Setter() // 采用线程池方式实现服务隔离 .withExecutionIsolationStrategy(HystrixCommandProperties.ExecutionIsolationStrategy.THREAD) // 禁止 .withExecutionTimeoutEnabled(false); return Setter.withGroupKey(groupKey).andCommandKey(commandKey).andThreadPoolKey(threadPoolKey) .andThreadPoolPropertiesDefaults(threadPoolProperties).andCommandPropertiesDefaults(commandProperties); } @Override protected Product run() throws Exception { System.out.println(Thread.currentThread().getName()); return restTemplate.getForObject("http://localhost:9001/product/findById/" + id, Product.class); } /** * 服务降级 * * @return */ @Override protected Product getFallback() { Product product = new Product(); product.setProductName("不好意思，出错了"); return product; } } 4.3 修改Controller package com.sunxiaping.order.controller; import com.sunxiaping.order.command.OrderCommand; import com.sunxiaping.order.domain.Product; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.client.RestTemplate; @RestController @RequestMapping(value = "/order") public class OrderController { @Autowired private RestTemplate restTemplate; /** * 使用OrderCommand调用远程远程服务 * * @param id * @return */ @GetMapping(value = "/buy/{id}") public Product buy(@PathVariable(value = "id") Long id) { return new OrderCommand(restTemplate, id).execute(); } @GetMapping(value = "/findOrder") public String findOrder() { System.out.println(Thread.currentThread().getName()); return "商品查询到了"; } }

2021-02-07

如何让测试同学理解并发锁

并发有一天，一个叫做 hulk 的小伙子捡到 1 个金币。同一时间，他挨了一刀，减少了 10 点生命值。

2021-02-07

并发条件队列之 Condition 精讲

总结以上便是Condition的分析，下一篇文章将是并发容器类的分析，如有错误之处，帮忙指出及时更正,谢谢，如果喜欢谢谢点赞加收藏加转发（转发注明出处谢谢！！！）

2021-01-27

并发容器(四) —— ConcurrentHashMap 和 Hashtable 的区别

实现线程安全的方式不同从原理上分析，Hashtable 实现并发安全的原理是通过 synchronized 关键字，从源码角度，以 clear() 方法为例，代码如下： publicsynchronizedvoidclear

2021-01-26

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。