apache flink TimerService回调和KeyedProcessFunction.processElement线程安全吗

文章/答案/技术大牛

发布

1回答

thread-safety、apache-flink

它们的线程对彼此是安全的吗？ onTimer()方法似乎是由一个TimerService头池调用的。所以在我看来他们可以在同一时间被执行。

浏览 15提问于2020-02-18得票数 0

回答已采纳

1回答

如何对无水印的flink联合数据流进行排序

apache-flink

flink流具有多个数据流，然后使用org.apache.flink.streaming.api.datastream.DataStream#union方法对这些数据流进行合并。Sorting union of streams to identify user sessions in Apache Flink 我得到了答案，但com.liam.learn.flink.example.union.UnionStreamDemo.SortFunction环境信息: flink</em

浏览 30提问于2019-01-12得票数 2

1回答

如何使用Flink* MiniCluster触发ProcessTimeTimer*

apache-flink、flink-streaming

但是我不能让KeyedCoProcessFunction中的onTimer()回调触发。import org.apache.flink.runtime.testutils.MiniClusterResourceConfigurationimport org.apache.flink.stre

浏览 0提问于2020-08-26得票数 3

1回答

Xcode thread 1:总是主UI线程吗？

ios、xcode、thread-safety

Xcode在Debug导航器中显示线程。我注意到我总是在thread 1中。假设它是主UI线程是正确的吗？我使用libs/SDK，比如Facebook和AFNetworking，它们有回调和委托。但是线程安全并不总是被正确地记录下来。

浏览 1提问于2013-03-13得票数 7

回答已采纳

1回答

Linux环境，计时器回调和应用程序线程之间的同步

linux、multithreading、timer、callback、synchronization

如果我在一个进程中有两个线程A和B，并且线程A创建了一个计时器，因为计时器回调可以中断任何一个线程，这是否意味着(在线程和计时器回调之间)对共享对象的访问需要同步？也有人说，定时器回调和应用程序线程之间的同步是不安全的，比如线程A锁定了一个互斥mA，然后被定时器回调中断，在定时器回调中它也试图锁定mA，这时死锁就发生了。我上面的陈述对吗？如果是真

浏览 17提问于2017-08-23得票数 0

回答已采纳

2回答

当我不应该使用FragmentManager的executePendingTransactions() (在主线程中)时，情况是什么？

android、android-fragments

executePendingTransactions的FragmentManager方法看起来可能有一些自己的方法，特别是因为在官方安卓文档中的描述中有这样的注释：听起来像是个很神秘的警告。这些“回调和其他相关行为”将如何影响我的应用程序？当从主线程调用此函数时，这会导致问题吗？我找不到任何具体的例子，所以我向那些对这个警

浏览 5提问于2013-04-27得票数 13

回答已采纳

1回答

Apache Flink中的ConnectedStreams线程安全吗

apache-flink、flink-streaming

我正在使用Apache Flink并使用机械ConnectedStreams。control = env.fromElements("DROP", "IGNORE");

浏览 28提问于2020-07-27得票数 0

回答已采纳

1回答

如何在不删除以前的值的情况下更新MapState上的值？

apache-flink、flink-streaming、flink-cep

这一次我的问题是:使用MapState，使用mapstate.put(key, value)将键的当前值修改到mapState中是安全的，或者我需要执行mapState.remove(key)，然后再次执行从Flink的状态抽象开始，抽象不是为并发访问而设计的，也不应该在多个线程之间共享。那么，重新表述我的问题:我可以根据键将值更新到mapState中，而不需要删除键然后再放入键吗？org.apache.flink.runtime.state.heap.HeapMapState.get(

浏览 43提问于2020-04-16得票数 1

2回答

DNS异步查找

ios、multithreading、asynchronous、dns

然而，这是同步的，因此在它返回之前阻塞任何东西--它是坏的，而且我也认为它会在连接弱时由于超时而导致崩溃(当连接弱时，它会安全地失败)。调用CFHostSetClient将客户端上下文和用户定义的回调函数与主机关联起来。然后调用CFHostScheduleWithRunLoop来调度运行循环中的主机。然而，这让我很不爽，因为我已经很久没有编写C代码了，并且无法正确地进行回调和运行循环/线程处理。我应该如何调用CFHostSetClient、CFHostScheduleWithRunLoop，以及

浏览 2提问于2013-08-30得票数 2

回答已采纳

1回答

Flink:实现DataStream和“规则集”之间的“连接”

apache-flink、flink-streaming

我们需要将流与一组“规则”相匹配，这些“规则”本质上是一个Flink DataSet概念。对此“规则集”的更新是可能的，但并不频繁。为了加快迭代速度，我们还可以将列表分成几个批，实质上是创建一个列表列表，并创建一个单独的线程来迭代每个子列表(使用Java或Scala中的Futures或Scala)。问题： p

浏览 1提问于2018-06-04得票数 0

回答已采纳

1回答

使用一个Java 8使用者作为可运行的回调-线程安全吗？

java、multithreading、callback、thread-safety、java-8

我有一个带有4个活动线程的ScheduledThreadPoolExecutor。它会被一堆任务填充，每个任务都处理一组项。 processedCallback.accept(taskId+" "+i); }我只是省略了开始回调和结束回调，因

浏览 0提问于2015-04-03得票数 4

回答已采纳

3回答

PHP上传和下载脚本

php

我该怎么做，有什么帮助吗？步骤1：步骤1:它显示了一个窗口，用户可以在其中浏览本地存储的文件并从中选择一个文件。他们点击upload。

浏览 0提问于2011-04-05得票数 1

回答已采纳

1回答

致命错误:在正确设置扩展时调用未定义函数mysqli_connect()

php、mysql、apache、mysqli

’，1)；error_reporting(E_ALL)**；是相同的**致命错误:调用未定义函数mysqli_connect() 哪一个要下载非线程安全还是线程安全我已经下载了非<

浏览 1提问于2013-06-22得票数 1

回答已采纳

3回答

从AppEngine的Servlet调用Web

java、web-services、google-app-engine、jakarta-ee、scalability

阻塞调用在AppEngine环境中是可伸缩的吗？上下文:我正在使用AppEngine和J2EE开发一个web应用程序。应用程序调用Amazon服务为用户获取一些信息。现在，我正在考虑使我的控制器(和servlet)线程安全，并将请求限定在范围内。还有什么我能做的吗？在J2EE + AppEngine环境中，这甚至是一个问题吗？据我所知，要完成servlet请求，代码仍然应该等待异步WS调用完成(回调或其他什么)。我假设使用同步原语执行此操作将阻止当前的工作线程。这个假

浏览 4提问于2011-09-19得票数 1

回答已采纳

5回答

CURL作为具有多个连接的下载管理器，并在PHP中显示进度

php、curl、download

CURL for PHP允许这样做吗？如果是这样的话，可以提供一些提示吗？

浏览 0提问于2009-10-23得票数 7

回答已采纳

4回答

需要全局清理的昂贵资源的线程安全缓存。

java、multithreading、caching

情况： ConcurrentHashMap似乎是个不错的选择，但它也受到内存泄漏的影响。还有什么其他的选择吗？(希望解决方案也可以像Supplier一样使用给定的Threa

浏览 0提问于2015-08-21得票数 2

回答已采纳

3回答

如何加快excel的读写速度

java、excel、apache、apache-poi

作为实习生，我正在使用Apache为我的公司读取/写入excel文件。我的程序通过excel文件，它是一个大方格，上面有行、计算机名和左列用户名。240台计算机和342个用户。有什么想法吗？

浏览 16提问于2015-07-06得票数 1

1回答

用于一系列计算的Rails服务

ruby、ruby-on-rails

record.pro_rated_amount recordend task :audit_records => :environment do end我非常关心线程安全这个代码线程安全</em

浏览 0提问于2016-06-20得票数 2

回答已采纳

8回答

Delphi线程和线程安全FormatDateTime崩溃

multithreading、delphi、winapi、formatdatetime

有一个版本的FormatDateTime据说是线程安全的，因为您使用得到一个值，然后你可以这样使用它；FQueueTimer, TimerCallback, 10, WT_EXECUTEINTIMERTHREAD现在的位，如果在回调和计时器事件我们已经查看了原始的C头文件，它们看起来都很好，C++使用Delphi有什么不同的方式吗？线

浏览 25提问于2008-12-09得票数 4

回答已采纳

6回答

如何在Visual C++ 2008中查找未使用的属性/方法

c++、visual-studio、visual-studio-2008、visual-c++、static-analysis

在Visual C++ 2008专业版中，有没有办法识别未使用的属性/方法？如果默认情况下这是不可能的，也非常感谢第三方工具的建议。弗洛里安

浏览 64提问于2008-09-29得票数 8

回答已采纳

点击加载更多