option("topic", "clickEventStatics") .start() new Thread(new Runnable { override def run(): Unit = { while(true) {

查看更多 →

percent", 0.1); archaius API支持callback处理配置变更： myprop.addCallback(new Runnable() { public void run() { // 当配置项的值变化时，该回调方法会被调用

查看更多 →

option("topic", "clickEventStatics") .start() new Thread(new Runnable { override def run(): Unit = { while(true) {

查看更多 →

当前实例中的有效Worker数量 ROWS/SEC 当前实例每秒处理的数据行数 Queued Queries 当前实例中等待队列中等待执行的任务数 RUNNABLE DRIVERS 当前实例中正在RUNNING的DRIVERS数量 BYTES/SEC 当前实例中每秒读取的数据量 Blocked Queries

查看更多 →

schedule_time String 构建下发耗时 queued_time String 构建排队耗时 start_time String 开始构建时间 runnable_time String 八爪鱼真正开始构建时间 finish_time String 构建结束时间 duration Integer

查看更多 →

schedule_time String 构建下发耗时 queued_time String 构建排队耗时 start_time String 开始构建时间 runnable_time String 八爪鱼真正开始构建时间 finish_time String 构建结束时间 duration Float 构建时长

查看更多 →

setPayload(payload.getBytes(StandardCharsets.UTF_8)); Runnable pubTask = () -> { try {

查看更多 →

option("topic", "clickEventStatics") .start() new Thread(new Runnable { override def run(): Unit = { while(true) {

查看更多 →

percent", 0.1); archaius API支持callback处理配置变更： myprop.addCallback(new Runnable() { public void run() { // 当配置项的值变化时，该回调方法会被调用

查看更多 →

executorService.execute( new Runnable() { @Override

查看更多 →

recognitionAfterRecording(); runOnUiThread(new Runnable() { @Override

查看更多 →

峰值线程数 峰值线程数。 线程状态 WAITING状态线程数 等待状态线程数量。 TERMINATED状态线程数 终止状态线程数量。 RUNNABLE状态线程数 运行状态线程数量。 BLOCKED状态线程数 阻塞状态线程数量。 NEW状态线程数 新状态线程数量。 TIMED_WAITING状态线程数

查看更多 →

ctime, @NonNull onSignatureSuccess callback) { new Thread(new Runnable() { @Override public void run() {

查看更多 →

jarfile="${jarfilename}" basedir="${classes}"> <!--为jar包指定manifest，当然，如果jar包不需要打成runnable的形式，manifest可以不要--> <manifest> <!--指定main-class--> <attribute

查看更多 →

cksDB的操作接口上。 Join[5] -> Calc[6] -> Sink: print[7] (1/1)#0" Id=113 RUNNABLE (in native) at org.rocksdb.RocksDB.put(Native Method) at org.rocksdb

查看更多 →

new状态的线程数 观测JVM线程数是否合理。 ≥0 60s SYS.CloudTable jvm_thread_runnable_count runnable状态的线程数 观测JVM线程数是否合理。 ≥0 60s SYS.CloudTable jvm_thread_blocked_count

查看更多 →

executorService.execute( new Runnable() { @Override

查看更多 →

producer.model.log.LogItem; public class LtsLogJavaSdkTest1 implements Runnable { @Override public void run() { /* 认证用的ak和sk

查看更多 →

model.log.StructLogItem; public class JavaSdkStructLogPush implements Runnable { /* 此结构体为一次批量上报结构化日志 { // 所用日志共用的自定义label

查看更多 →

< CONSUMER_COUNT; i++) { // 启动消费者, ClientConsumerWorker实现了Runnable接口, Thread启动后, 内置的消费任务会自动运行 threads[i].start(); } Thread

查看更多 →

final int partNumber = i + 1; executorService.execute(new Runnable() { @Override public void run() {

查看更多 →