异步化IO多线程上传示例

本文为您介绍如何通过StreamRecordPack接口实现IO与业务逻辑异步化。import java.io.IOException;import java.util.ArrayList;import java.util.Date;import java.util.concurrent.*;import java.util.concurrent.atomic.AtomicBoolean;...

异步处理

线程中使用 java.lang.Runnable如果您在代码中通过 java.lang.Runnable 新启动了线程或者采用了线程池去异步地处理一些业务,那么需要将 SOFATracer 日志上下文从父线程传递到子线程中去,SOFATracer 提供的 ...您可以按照以下方式使用:...

使用ARMS监控异步任务

异步透传扫描包中的Runnable、Callable和Supplier接口在创建新对象时会自动捕获当前线程调用链的上下文,并在异步线程中执行时使用该调用链上下文,完成串联。登录ARMS控制台。在左侧导航栏,选择应用监控>应用列表。在顶部菜单栏,选择...

SDK多值写入

本文通过示例代码指导您使用...TSDBConfig config=TSDBConfig.address("127.0.0.1",8242).httpConnectTimeout(90)/批次写入时每次提交数据量.batchPutSize(500)/单值异步写入线程数.batchPutConsumerThreadCount(1)/多值异步写入缓存队列长度....

SDK多值写入

本文通过示例代码指导您使用...TSDBConfig config=TSDBConfig.address("127.0.0.1",8242).httpConnectTimeout(90)/批次写入时每次提交数据量.batchPutSize(500)/单值异步写入线程数.batchPutConsumerThreadCount(1)/多值异步写入缓存队列长度....

SDK多值写入

本文通过示例代码指导您使用...TSDBConfig config=TSDBConfig.address("127.0.0.1",8242).httpConnectTimeout(90)/批次写入时每次提交数据量.batchPutSize(500)/单值异步写入线程数.batchPutConsumerThreadCount(1)/多值异步写入缓存队列长度....

启动加速-异步初始化方法

为了加速应用启动,SOFABoot 通过配置可选项,将 Bean 的初始化方法(init-method)使用单独线程异步执行,加快 Spring 上下文加载过程,提高应用启动速度。异步加速实现异步初始化 Bean 的原理是开启单独线程负责执行 Bean 的初始化方法...

如何提升写入效率

异步和同步写入优化 异步写:异步写入调用put()方法即可;SDK的内部处理逻辑为:1)将Points放入内部队列;2)消费者线程从内部队列取出小于等于批次大小个数据点,发送个TSDB服务端;同步写:同步写调用putSync()方法即可;SDK的内部处理...

TSDBConfig

intgetBatchPutConsumerThreadCount()获取异步提交缓冲区消费线程数。intgetBatchPutRetryCount()获取重试次数。intgetBatchPutSize()获取自动打包每批次提交的点数。intgetBatchPutTimeLimit()获取最大写数据提交限制。单位:毫秒...

配置 TSDBConfig 类

batchPutBufferSize(20000)/异步写相关,缓冲队列消费线程数,默认为 1。batchPutConsumerThreadCount(2)/异步写相关,每次批次提交给客户端点的个数,默认为 500。batchPutSize(500)/异步写相关,每次等待最大时间限制,单位为 ms,默认为...

配置 TSDBConfig 类

batchPutBufferSize(20000)/异步写相关,缓冲队列消费线程数,默认为 1。batchPutConsumerThreadCount(2)/异步写相关,每次批次提交给客户端点的个数,默认为 500。batchPutSize(500)/异步写相关,每次等待最大时间限制,单位为 ms,默认为...

TSDBConfig

getBatchPutCallback()获取异步提交缓冲区消费线程数。int getBatchPutConsumerThreadCount()获取重试次数。int getBatchPutSize()获取自动打包每批次提交的点数。int getBatchPutTimeLimit()获取最大写数据提交限制。单位:毫秒 int ...

Memcg后台异步回收

该功能的实现不同于全局kswapd内核线程的实现,并没有创建对应的memcg kswapd内核线程,而是采用了workqueue机制来实现,并在cgroup v1和cgroup v2两个接口中,均新增了4个memcg控制接口。注意事项:当前memcg的内存分配,可能会递归触发父...

TSDBConfig.Builder

TSDBConfig.Builder batchPutConsumerThreadCount(int batchPutConsumerThreadCount)异步写相关,设置缓冲队列消费线程数,默认为1。TSDBConfig.Builder batchPutSize(int batchPutSize)异步写相关,设置每次批次提交给客户端点的个数,...

异步调用

本文介绍HSF如何进行异步调用。前提条件 在开发应用前,您已经完成以下工作:配置EDAS的私服地址和轻量配置中心 启动轻量级配置及注册中心 同步调用 HSF的IO操作是异步操作,客户端同步调用的本质是执行future.get(timeout)操作,等待...

管理函数异步调用

函数计算支持异步调用函数,让您可以将函数的执行状态信息例如执行中、执行失败或执行成功等发送给其他目标服务,您也可以设置异步调用的重试次数和消息存活时长。本文介绍函数异步调用的基本概念、适用场景和使用限制等。什么是异步调用 ...

异步调用

本文介绍HSF如何进行异步调用。前提条件 在开发应用前,确保您已完成以下操作:配置SAE的私服地址和轻量级配置及注册中心 启动轻量级配置及注册中心 同步调用 HSF的IO操作是异步操作,客户端同步调用的本质是执行future.get(timeout)操作...

初始化

异步接口相比同步接口更加灵活,如果对性能有一定需求,可以在使用异步接口和使用多线程之间做一些取舍。说明 不管是SyncClient还是AsyncClient,都是线程安全的,且内部会自动管理线程和管理连接资源。不需要为每个线程创建一个Client,也...

有状态异步调用最佳实践

有状态异步调用可以实时感知业务状态、控制执行函数,让您对一些异常情况进行更好的处理,例如报警通知、自动化重试等情况。本文介绍函数计算有状态异步调用的最佳实践。背景信息 FaaS早期主要支持无状态、短时和轻量级的计算能力,例如API...

TSDBConfig.Builder

batchPutConsumerThreadCount(int batchPutConsumerThreadCount)异步写相关,设置缓冲队列消费线程数,默认为1。basicAuth(String tsdbUser,String basicPwd)用户认证相关。配置认证时所用的TSDB的用户名和密码。该方法自SDK的0.2.7版本...

ListStatefulAsyncInvocations

调用ListStatefulAsyncInvocations接口获取有状态异步调用中符合某些条件的所有异步调用。请求头 该接口无特殊请求头,关于公共请求头信息,请参见公共参数。请求语法 GET/services/{serviceName[.qualifier]}/functions/{functionName}/...

PutFunctionAsyncInvokeConfig

调用PutFunctionAsyncInvokeConfig接口创建或更新函数的异步调用配置。函数会根据异步调用配置是否存在,在调用PutFunctionAsyncInvokeConfig接口时创建或更新相关配置信息。如果函数的异步调用配置不存在,调用...

线程池监控

您可以通过线程池监控功能监控具体应用所使用的线程池的各项指标,包括核心线程数量、当前线程数量、最大线程数量、活动线程数量、提交任务数量和任务队列容量。前提条件 接入应用监控 注意 仅专家版支持线程池监控功能。开启线程池监控 ...

函数调用概述

同时,异步调用包含以下调用方式:无状态异步调用:无状态异步调用会确保函数至少执行一次。当出现系统硬件错误、系统升级等一些特殊情况时,函数可能会被多次执行,从而保证每条消息都会被处理。说明 默认开启无状态异步调用。有状态异步...

异步调用

开启异步调用发起异步调用关闭异步调用Alibaba Cloud SDK for Go 支持两种方式开启异步调用:注:开启异步调用之后需要先调用 Shutdown()才能再次开启异步调用。初始化 client 的时候开启异步调用import("github....

API 概览

asyncTransferBalance 交易转账,异步调用。setRecoverKey 设置恢复公钥,同步方式调用。asyncSetRecoverKey 设置恢复公钥,异步方式调用。preResetPubKey 预重置公钥,同步方式调用。asyncPreResetPubKey 预重置公钥,异步方式调用。...

GetStatefulAsyncInvocation

调用GetStatefulAsyncInvocation接口查询有状态异步调用。请求头 该接口无特殊请求头,关于公共请求头信息,请参见公共参数。请求语法 GET/services/{serviceName[.qualifier]}/functions/{functionName}/stateful-async-invocations/{...

Async优化

asyncCallbackThreads 回调处理线程数 否 回调类中的onComplete和onError默认会在线程池中处理该线程池的大小,默认值为50。asyncConnectionQueueMaxsize 最大请求发送数 否 当等待某个服务器返回结果的请求数量达到...

消息堆积和延迟问题

消费逻辑中的复杂耗时的操作是否可以做异步化处理,如果可以是否会造成逻辑错乱(消费完成但异步操作未完成)。设置消息的消费并发度 逐步调大线程的单个节点的线程数,并观测节点的系统指标,得到单个节点最优的消费线程数和消息吞吐量。...

GetFunctionAsyncInvokeConfig

调用GetFunctionAsyncInvokeConfig接口查询一个服务下某个函数的异步调用配置。请求头 该接口无特殊请求头,关于公共请求头信息,请参见公共参数。请求语法 GET/services/{serviceName[.qualifier]}/functions/{functionName}/async-invoke...

常数吞吐量分布式使用示例

All cative threads in current thread group(shared)将设置的吞吐量,分配到活跃的线程上(当前线程组的活跃线程),所有线程都会在所有活跃线程运行结束之后即所有活跃线程结束之后,等待合理时间(为了控制吞吐量)再次运行。当前线程...

Thread Pool

为了发挥出RDS的最佳性能,阿里云提供线程池(Thread Pool)功能,将线程和会话分离,在拥有大量会话的同时,只需要少量线程完成活跃会话的任务即可。优势 MySQL默认的线程使用模式是会话独占模式,每个会话都会创建一个独占的线程。当有...

异步执行

使用异步执行工具执行 SQL 语句的步骤如下:进入 异步执行 面板。进入 ODC 单击目标连接进入对应的数据库对象管理页面后,单击上方导航栏中的 工具 标签,在弹出的下拉菜单中选择 异步执行 以弹出 新建异步执行 面板。指定 任务名称。在...

线程分析

线程分析功能提供线程粒度的CPU耗时和每类线程数量的统计,并且每5分钟记录一次线程的方法栈并聚合,可真实还原代码执行过程,帮助您快速定位线程问题。当发现集群的CPU使用率过高,或者出现大量慢方法时,可以通过线程分析功能找到消耗CPU...

API概览

asyncTransferBalance 交易转账,异步调用。setRecoverKey 设置恢复公钥,同步方式调用。asyncSetRecoverKey 设置恢复公钥,异步方式调用。preResetPubKey 预重置公钥,同步方式调用。asyncPreResetPubKey 预重置公钥,异步方式调用。...

线程分析

线程分析功能提供线程粒度的CPU耗时和每类线程数量的统计,并且每5分钟记录一次线程的方法栈并聚合,可真实还原代码执行过程,帮助您快速定位线程问题。当发现集群的CPU使用率过高,或者出现大量慢方法时,可以通过线程分析功能找到消耗CPU...

定义资源

} catch(BlockException ex){/Request blocked/Handle the exception(e.g.retry or fallback)} SphU.asyncEntry(xxx)不会影响当前调用线程的 Context,因此以下两个 entry 在调用链上是平级关系(处于同一层),而不是嵌套关系:/调用链...

设置异步通知

设置异步通知,首先需要在消息服务控制台创建事件通知规则,然后再到邮件推送控制台新建异步通知,所以需要开通消息服务。消息服务可能会产生费用。设置异步通知时使用阿里云主账号,消息服务目前不支持子账号创建事件通知规则建议在创建...

ListFunctionAsyncInvokeConfigs

调用ListFunctionAsyncInvokeConfigs接口查询一个服务下某个函数的所有异步配置。当配置个数超过Limit个数时,将返回NextToken参数。可以使用该参数进行后续的分页查询。请求头 该接口无特殊请求头,关于公共请求头信息,请参见公共参数。...

服务端线程池配置

线程池最小配置:Dhsf.server.min.poolsize 线程池最大配置:Dhsf.server.max.poolsize 线程收敛的存活时间:Dhsf.server.thread.keepalive 服务线程池配置 对于一些慢服务、并发高,可以为其单独配置线程池,以免占用过多的业务线程,影响...
< 1 2 3 4 ... 62 >
跳转至: GO

新品推荐

你可能感兴趣

热门推荐

新人福利专场 阿里云试用中心 企业支持计划 飞天会员助力企业低成本上云 智能财税30天免费试用 云解析DNS新用户首购低至36元/年起 ECS限时升级特惠6.5折