RxJava在另一个线程上运行任务
RxJava是一个在Java虚拟机上实现的响应式编程库，它提供了一种简洁而强大的方式来处理异步事件流和基于事件的编程。RxJava基于观察者模式和迭代器模式，通过使用可观察序列（Observable）和观察者（Observer）来实现异步编程。
在RxJava中，可以使用Schedulers来指定任务在不同的线程上运行。通过使用Schedulers.io()调度器，可以将任务放在一个专门用于I/O操作的线程池中运行，以避免阻塞主线程。Schedulers.io()适用于执行网络请求、文件读写等I/O密集型操作。
使用RxJava在另一个线程上运行任务的优势包括：
- 异步执行：将任务放在另一个线程上运行，可以避免阻塞主线程，提高应用的响应性能。
- 线程池管理：RxJava使用线程池来管理任务的执行，可以有效地管理线程资源，避免创建过多的线程。
- 简化线程切换：RxJava提供了丰富的操作符，可以轻松地在不同的线程之间切换，简化了线程切换的操作。
在腾讯云中，可以使用腾讯云函数（SCF）来运行RxJava任务。腾讯云函数是一种无服务器计算服务，可以让您以事件驱动的方式运行代码，无需关心服务器的管理和维护。您可以将RxJava任务封装为一个腾讯云函数，并使用SCF提供的异步执行能力，在另一个线程上运行任务。
腾讯云函数相关产品和产品介绍链接地址：
- 腾讯云函数（SCF）：https://cloud.tencent.com/product/scf
通过使用腾讯云函数（SCF）来运行RxJava任务，您可以充分利用腾讯云的弹性计算能力和高可用性，实现高效的异步编程。
相关·内容
在Kotlin中，可以通过指示要使用什么调度程序(IO、Main等)来指定希望在其上运行的线程类型。以类似的方式，使用rxJava，您还可以指示要在哪个线程上运行。但是，使用rxJava，您通常会在IO线程上运行一些东西来完成后台工作，然后切换到主线程(即UI线程)来显示内容。
但是，我已经看到了很多代码，其中coroutine只使用主线程。它不会从IO线程切换到主线程。我还没有在rxJava中看到这种情况，尽管我确信它是存在的。
但我的问题是你为什么要这么做？如果您只使用主线程，那么为什么还要使用coroutine或rxJava呢？在主线程上运行协同线不是与在没有协同线的主线程上运行协同线相
浏览 3提问于2019-10-27得票数 2
回答已采纳
2回答
我正试图从RxJava迁移到当前项目的协同机制。所以我正在看官方医生，我偶然发现了Dispatchers。根据正式文件，他们将调度员定义为：
Coroutine上下文包括一个CoroutineDispatcher(请参阅CoroutineDispatcher)，它确定对应的coroutine用于执行的线程。可以将协同执行限制在特定的线程上，将其分派到线程池，或者让它不受限制地运行。
线程池是什么意思？Dispatchers.IO或Dispatchers.Default是不同的线程吗？我对这里的“线”一词感到困惑。有人能解释一下这是怎么回事吗？
浏览 1提问于2019-06-09得票数 1
2回答
TL；DR -在默认情况下，在观察可观测事件时只使用一个线程吗？
在我看来，RxJava2通常是顺序的，除非通过并行()之类的东西来表示。即使对doOnNext()进行了观察/订阅，我仍然看到，对于()，从来没有两个线程同时运行：
AtomicInteger counter = new AtomicInteger();
PublishSubject<Integer> testSubject = PublishSubject.create();
testSubject
.observeOn(Schedulers.io())
.doOnNext(val -> {
if(c
浏览 1提问于2019-07-23得票数 2
回答已采纳
3回答
我是RxJava的新手，所以这可能是一个愚蠢的问题。我将描述我的场景。
我有一些代码运行在UI线程上，这些代码将更新一些图像，但这些图像并不是很重要，而且它们在生成它们时会消耗一些资源，所以我希望在单个线程(当然不是UI线程)上生成它们，并逐个生成它们。我猜我想要的是trampoline调度器，但我的问题是，如果我使用它，那么它会在UI线程上执行工作，而我希望它在另一个线程上执行。
显然，我可以编写自己的线程，在其中我可以对项进行排队，然后它会逐个处理这些项，但我想也许RxJava会为我提供一个简单的解决方案？
我当前的代码如下所示：
Observable<Bitmap> getI
浏览 0提问于2015-04-18得票数 23
回答已采纳
我正在使用web3j库在Java语言中为以太区块链开发一个负载测试应用程序。此库中使用的特定函数，异步发送事务，并返回Future对象。该库提供了许多特性，这些特性最初满足了我在应用程序开发方面的所有需求。然而，在设计和重新设计负载测试应用程序之后，我注意到了一个问题。我一次只能部署N个Futures，其中N是我的机器上可用核心的数量。
这是非常低效的，因为每个交易至少需要10秒才能集成到区块链中，而Futures在后台持续运行。如果它们被转换为RxJava可观察对象(使用RxJava的from()函数)，它们是否仍然会在后台持续运行，以检查其数据是否可用，或者我是否能够一次覆盖许多检查。例如
浏览 8提问于2017-06-30得票数 0
回答已采纳
我在类(A)中创建了一个任务，然后异步调用，然后如果任务完成或取消，传递结果另一个类(B)，在rxJava2中使用，在rxJava2中是非常新的，我可以使用这个逻辑吗?I confused.What？可完成的还是可流动的？ 我想做的是 调用异步任务类(B)，运行任务并发出一些结果类(A)，然后在类(B)中订阅任务结果，你有什么想法吗？感谢您的建议
浏览 15提问于2019-01-17得票数 0
回答已采纳
我在用RxJava。我必须每5秒执行一次特定的任务。通过使用"Observable.Interval“方法，这是非常有效的。但是，我也有以下约束:如果最后一个任务没有完成，就不能执行新任务。在这种情况下，只有在最后一个任务完成时才需要执行新任务。
我不知道如何简单地使用RxJava来完成这个任务。
所有的想法都会很感激^^
感谢您的阅读。
浏览 1提问于2016-12-10得票数 11
回答已采纳
我正在阅读RxJava的文档，并偶然发现这一点，我不太明白。
RxJava中的流在本质上是顺序的，分为处理阶段，这些处理阶段可以彼此并行运行：
Flowable.range(1，10) .observeOn(Schedulers.computation()) .map(v -> v* v) .blockingSubscribe(System.out::println)；
关于这段代码的任何东西，我都不认为它会同时运行。
浏览 3提问于2017-07-03得票数 0
我面临一个问题，rxjava操作符正在UI线程中运行。我使用findAllAsync()异步获取对象，使用asFlowable()使用rxjava操作符处理它们。
realm.where(Specie.class)
.equalTo("fauna", true)
.findAllAsync().asFlowable()
.filter(new Predicate<RealmResults<Specie>>() {
@Override
浏览 2提问于2017-11-02得票数 0
回答已采纳
5回答
我使用RxJava可观察的api编写了以下代码：
Observable<Info> observable = fileProcessor.processFileObservable(processedFile.getAbsolutePath());
observable
.buffer(10000)
.observeOn(Schedulers.computation())
.subscribe(recordInfo -> {
_logger.info("Running stage2 on thread wit
浏览 3提问于2016-02-16得票数 39
回答已采纳
我知道这是我们多次提出的问题。然而，有件事我从来没有找到答案。希望有人能给我点启发。
我们都知道AsyncTask和Thread是执行后台任务以避免ANR问题的选项。建议异步任务只用于短时间运行的任务，而线程可以用于长时间运行的任务。异步任务不应该用于长任务的原因是众所周知的，这与异步任务可能导致的泄漏有关，因为它可能在活动被破坏后继续运行。这是令人信服的。然而，它也导致了其他一些问题：
线程不是也独立于活动生命周期吗？因此，异步任务的风险也可以应用于线程。那么，为什么线程适合长期运行的任务呢？
看起来，异步任务的风险仅在与活动一起使用时才适用。如果我们在服务中使用它(而不是Inten
浏览 1提问于2016-10-05得票数 12
回答已采纳
我是Rxjava的初学者，我不知道如何用Rxjava的方式表达红色和黄色的箭头。
对我来说，困难是：
收集所有可观察到的数据，但不交叉。…的数目
可观测值是可变的，而不是红色箭头中的固定数。
我读过书和搜索，但越来越头痛，我不知道我应该走哪条路。对于红色箭头部分，我可以像往常一样使用阻塞队列，但最好用Rxjava方式编写整个链。
浏览 0提问于2016-10-10得票数 0
1回答
我如何在另一个线程上运行RxJava，因为在主线程上有太多的工作。
我让观察者在一个方法中运行，下面是代码片段：
public void updatePie() {
RxJavaPlugins.setErrorHandler(Functions.<Throwable>emptyConsumer());
Observable<Long> intervalObservable = Observable
.interval(1, TimeUnit.SECONDS)
//.doOnError(Functions.<Throwable>
浏览 2提问于2020-06-04得票数 0
我使用的是Rxjava2和弹簧引导。
我在服务器上有500个并发请求。
每个请求产生10个线程，它们调用其他服务(所以IO工作)。
所以在这种情况下，我应该使用Schedulers.io()还是Schedulers.compuatation()。
基本上，我的困惑是，理想情况下，应该使用io()，因为这是IO工作，但这可能会创建大量线程？
我还可以指定计算线程的池大小吗？我还可以指定io线程的池大小吗？
浏览 2提问于2018-04-05得票数 2
我对并行编程比较陌生，需要在不同的线程上运行后台进程。
场景是这样的--某些东西会导致第一个后台进程运行--它可能需要45秒(例如)才能完成。同时，在第一个后台进程运行后的某个任意点，会发生另一个事件，这反过来会导致第二个后台进程运行--比如20秒内。我不想再等待25秒来完成第一个进程，我想让第二个进程立即在另一个线程上运行。但是，我也想限制可以被抛弃的线程的数量。
我是否需要使用BackgroundWorker对象或类似对象创建某种队列类？对于这种情况，最好的方法是什么？
浏览 0提问于2013-05-10得票数 2
回答已采纳
1回答
我有一个非常简单的RxJava示例
List<Integer> arrayIntegers = new ArrayList<>(Arrays.asList(1, 2, 3, 4, 5));
Observable.fromIterable(arrayIntegers).map(i -> {
Log.d("RxJava", "map i = " + i);
return i;
}).subscribeOn(Schedulers.newThread()).observeOn(AndroidSchedulers.mainT
浏览 5提问于2017-11-01得票数 1
回答已采纳
1回答
我不确定使用不同的调度程序从rxJava链读取/写入实例变量的安全性。有一个很小的例子
public class RxJavaThreadSafety {
private int variable = 0;
// First call
public void doWriting() {
Single.just(255)
.doOnSuccess(
newValue -> variable = newValue
)
浏览 3提问于2020-08-17得票数 0
回答已采纳
1回答
我有个问题。在RxJava的单线程环境中可以异步运行两个任务吗？我知道Java应该包含用于此功能的库，但我认为RxJava没有包含它。
浏览 12提问于2018-01-16得票数 1
回答已采纳
在我当前的项目中，我正逐渐从RXJava过渡到Coroutines。在这种情况下，我需要停止执行并等待回调返回的结果。我已经将我的RXJava方法转换为以下列方式使用协同：
suspend fun fetchProducts(ids: List<String>) = suspendCoroutine<List<ProductItem>> { continuation ->
val getProducts = repo.search(ids, null, null)
getProducts.subscribe(
{
浏览 1提问于2021-02-09得票数 0
很少的接口调用得到RunTime异常，并且不能理解根本原因。
INFO | jvm 1 | main | 2020/02/28 14:04:34.738 | java.lang.RuntimeException: java.util.concurrent.TimeoutException
INFO | jvm 1 | main | 2020/02/28 14:04:34.738 | at rx.observables.BlockingObservable.blockForSingle(BlockingObservable.java:463) ~[rxja
浏览 21提问于2020-02-28得票数 0
2回答
你好，RxJava大师，
在我当前的Android项目中，我在使用RxJava和SQLite时遇到了一些死锁问题。我的问题是：
我在线程上启动一个事务。
调用web服务并在数据库中保存一些内容
concat映射另一个可观测函数
尝试在数据库上编写其他内容
这是我的代码：
//define a scheduler for managing transaction in the same thread
private Scheduler mScheduler = Schedulers.from(Executors.newSingleThreadExecutor());
浏览 2提问于2016-07-06得票数 4
3回答
我已经对此进行了研究，我知道RXJava正在使用可观察的模式，而Bolts则依赖于执行器。什么样的框架才能更好地处理需要在序列中完成的任务？
我听说过使用singleExecutors、队列、链接异步任务以及这两个框架。我见过更多的人使用螺栓和rxjava，但我很想知道人们在这两者之间的经历。
谢谢!
浏览 3提问于2016-07-18得票数 7
回答已采纳
我最近浏览了一下，想找到的答案，但没有针对这样做的风险的问题的答案。但基本上我想在另一个AsyncTask的doInBackground()方法中运行另一个AsyncTask。这是一种糟糕的方法吗?或者它是否会留下任何潜在的副作用？
我知道在onPostExecute()中运行它是可行的，从过去的经验来看，我没有遇到过任何问题，因为onPostExecute()是在启动AsyncTask的主线程上运行的。
浏览 2提问于2013-03-27得票数 1
回答已采纳
是否可以确保任务在另一个线程上运行，而不是在主线程上运行？这样这段代码就不会阻塞调用线程？
var task = Task.Run(() =>
{
//third party code i don't have access to
Thread.Sleep(3000);
});
我知道存在Task.Delay，但我希望确保任务将在另一个线程上运行。
浏览 3提问于2017-01-09得票数 6
回答已采纳
下面是依赖项
compile 'com.squareup.retrofit2:retrofit:2.2.0'
compile 'io.reactivex.rxjava2:rxjava:2.0.7'
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
compile 'com.squareup.retrofit2:adapter-rxjava:2.2.0'
compile 'com.google.code.gson:gson:2.7'
compile 'com.squ
浏览 2提问于2017-03-29得票数 2
回答已采纳
1回答
我希望从flatMap发出的每一项都在自己的线程上运行。
这是一个简化的实际使用示例，其中每个项目都将是一个url请求。
在每个线程上添加subscribeOn(Schedulers.io())仍然在单个线程上运行
这里的规矩是什么？
Integer[] array= new Integer[100];
for (int i = 0; i < 100; i++){
array[i] = i+1;
}
Observable.fromArray(array)
.flatMapSingle(new Function<Integer, SingleSource&l
浏览 2提问于2020-12-17得票数 2
回答已采纳
我正在尝试使用ml-kit运行多个进程，我已经搜索过了，我找到的唯一解决方案是要么连续执行所有任务(如何？)或者使用RXJava和压缩实用程序，但这似乎不符合我的需要。
我试着写了下面的代码，但我不确定它有多好，这是一个好的方法吗？
override fun analyze(image: ImageProxy) {
val inputImage = InputImage.fromMediaImage(image.image!!, image.imageInfo.rotationDegrees)
val tasks = mutableListOf<Task<*>
浏览 4提问于2021-10-07得票数 0
所以我跳过一个经常使用RxJava的项目。它分裂成模块，所以它就像项目中的不同实体。我想要建立一个新的模块，我想把它建立在Kotlin Coroutines上。我觉得这不应该是个问题，但我还是要问。您还能在同一个项目下同时使用Kotlin和RxJava吗？谢谢。
浏览 9提问于2022-09-29得票数 0
回答已采纳
我在Intellij中创建了一个maven项目，我正在尝试执行以下简单的rxjava代码
Observable.just(1,2,3,4)
.observeOn(Schedulers.io())
.subscribe(new Consumer<Integer>() {
@Override
public void accept(Integer integer) throws Exception {
System.out.println(integer);
浏览 0提问于2018-12-08得票数 1
回答已采纳
1回答
ReactiveX和安卓后台服务
、、、、
这更多地是一个概念性的问题，而不是一个编程问题。
我目前正在使用ReactiveX (RxJava + RxAndroid)来运行间隔计时器，因为其他计时器的方法在毫秒内太不准确了。据我所知，ReactiveX需要几个线程才能正确操作。
当用户不在应用程序本身时，我需要计时器在后台运行。但是从阅读Services文档来看，后台服务似乎只能在主线程上运行。我想知道是否仍然可以在后台运行ReactiveX计时器，尽管有此限制。实现服务将需要对我的项目进行一些重大更改，所以我想在这样做之前我会尝试询问。
这个项目是用科特林写的，但我怀疑这有什么关系。然而，任何关于这段代码在Kotlin中会是什么样子
浏览 4提问于2020-07-02得票数 0
回答已采纳
Loaders和AsyncTask对于像执行网络http请求这样的长时间运行操作来说非常容易使用和有用的类，但是由于它们被废弃了，所以我找不到替代的方法。我知道我可以像谷歌建议的那样使用LiveData + ViewModel，但是他们并不是在一个单独的线程中执行任务，那么除了它们我们还能使用什么呢？RxJava？还是别的什么？(不管手动创建Threads和Executors)
*我使用Java。
浏览 6提问于2020-07-06得票数 1
回答已采纳
如何在安卓系统中使用RxJava (或RxAndroid等)而不是AsyncTask来防止上下文泄漏？在AsyncTask中，如果执行它并且用户离开应用程序，那么活动上下文可能为null，应用程序可能崩溃。我听说RxJava在执行线程时可以帮助防止这种类型的崩溃。我还听说，它可以比doInBackground的AsyncTask方法(它处理错误很糟糕)做更好的错误处理。大多数情况下，我只是在doInBackground中返回null (例如)，如果有任何失败的话，但是我已经看到RxJava可以返回确切的错误而不是泄漏。有人能举个例子吗？
如果用户在尝试向UI报告结果时离开应用程序，下面是Asy
浏览 3提问于2015-02-04得票数 7
回答已采纳
我是RxJava新手，我选择使用它，因为我认为它非常适合我的用例。
我有一些Integer值，我想在无限的时间内观察。每当其中一个值更改(即事件)时，我希望在(另一个线程)上调用它的所有观察者。
由于需要很长的观察时间，我认为我需要使用BehaviorSubject类(虽然最初我认为Observable是我所需要的。考虑到我只需要“观察”)，我可以使用subscribeOn()方法来设置调度程序，从而实现在后台线程上调用订阅者：
private BehaviorSubject<Integer> rotationPositionSubject = BehaviorSubject.cr
浏览 0提问于2019-01-06得票数 4
回答已采纳
在处理各种背压场景时，我实现了这样一种情况:一个订阅者使用缓冲区的速度很慢，而另一个订阅者则消耗掉扔给它的任何东西。使用Scala和Akka Streams。如果愿意，您可以查看代码以及运行它的测试。
我通常尝试开发一个RxJava版本来进行比较，但我在这个版本上卡住了。在Akka Streams中，我可以构建一个图，其中一个源在2个通道上广播，并从这些通道消耗一个慢接收器和一个快速接收器。每个通道可以独立地应用缓冲和节流。在RxJava中，有用于广播的share操作符，但是缓冲和节流逻辑不在Subscriber上，而是在Observable上。因此，我不确定如何应用缓冲和节流，而不影响两个订
浏览 1提问于2016-09-02得票数 2
3回答
我有一个带有Room数据库的测试项目。使用Asynctask，我可以成功地将带有一些测试数据的对象插入到数据库中。我正在努力学习RxJava，并将Asynctask替换为RxJava's observer，但它不起作用。我读过很多文档，也看过教程，但我不太明白。以下是相关代码：
在这里，我用来自我的Room的数据来设置我的List对象
for(ObjectForArray item: listToDatabase) {
myRoomEntity.setName( item.getName() );
Log.d( "TAG", myRoom
浏览 0提问于2019-07-20得票数 0
回答已采纳
我是RxJava的新手，目前正在使用RxJava的第1版。我的用例就像我必须进行一个rest调用(使用rest模板)。因此，在这种情况下每次使用Schedulers.computation()或任何调度程序是否更好。
我的课就像
SampleController.java
@RequestMapping(value = "/", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
public DeferredResult<List<Response>
浏览 7提问于2017-12-21得票数 0
1回答
您好，我正在使用RxJava进行磁盘存储get和set操作。基本上我有一个这样的方法：
public Observable<String> getStorageItem(String id, String type) {
return Observable.defer(new Func0<Observable<String>>() {
// Run db operations to get storage item.
}
}
问题是，这个方法getStorageItem(...)可能会在一行中被多次订阅。并且observabl
浏览 0提问于2016-03-11得票数 0
我有一个调用webservice的方法，我认为这个方法在IO线程上运行，直到服务停止，UI冻结。
所以我开始了一些简单的测试来检查线程
implementation 'io.reactivex.rxjava2:rxandroid:2.0.1'
implementation 'io.reactivex.rxjava2:rxjava:2.1.8'
public void test() {
disposableRx.add(
Observable.just(1, 2)
.subscribeO
浏览 0提问于2018-01-19得票数 8
回答已采纳
3回答
我正在使用rxjava进行一些上传任务到服务器，每当任务启动的片段或活动被销毁时，我将处理订阅以避免内存泄漏，但我想要的是即使在销毁了片段/活动之后，我也需要继续在后台运行的任务，有什么方法可以做到吗？
示例
doSomeLongRunningBgTaks()
.subscribe()
.addTo(compositeDisposal)
override onDestroy(){
compositeDisposal.clear()
}
是否必须随时释放订阅？如果不是什么时候使用处置？
浏览 1提问于2019-09-11得票数 2
回答已采纳
2回答
这个问题与通常的Android仿真器相反。
我的Android工具测试(对基于RxJava的应用程序使用Espresso )在我的开发机器上运行得很好，但它们偶尔在构建服务器上失败。
我的构建服务器的硬件比我的机器慢。我认为这会导致在后台任务完成之前执行实际的Espresso检查。我知道Espresso在默认情况下不会等待RxJava调度程序(io()和计算())完成，所以这可能是原因。
有几种方法可以让Espresso知道RxJava调度程序，但是在实现它们之前，我想在我的机器上重现这个问题。
我试过禁用硬件加速，但没有效果。
在配置中，您可以设置网络速度和延迟，但在本例中，我感兴趣的是降低
浏览 3提问于2017-09-26得票数 5
回答已采纳
我的代码是这样的：
timingObservable = getCurrentModule()
.zipWith(Observable.interval(200, TimeUnit.MILLISECONDS), (currentModule, interval) -> currentModule)
.repeat()
.distinctUntilChanged()
.getModuleDataFromDb()
compositeDisposable.add(t
浏览 1提问于2020-06-25得票数 0
回答已采纳
谁知道如何将Firebase与RxJava连接起来，这样当我从数据库加载所有数据时，它就会运行arrayAdapter.notifyDataSetChanged() ?？我正在考虑用onComplete()方法编写它，但它仍然在加载所有数据之前运行
Completable.fromCallable(new Callable<List<cards>>() {
@Override
public List<cards> call() throws Exception {
浏览 0提问于2020-06-05得票数 1
我想知道CompletableFuture，Future和Observable RxJava之间的区别。
我所知道的都是异步的但是
Future.get()阻塞线程
CompletableFuture给出了回调方法
RxJava Observable --类似于CompletableFuture的其他好处(不确定)
例如:如果客户端需要进行多个服务调用，并且当我们使用Futures (Java)时，Future.get()将被执行，sequentially...would想知道如何在RxJava中更好。
而文档说
很难使用期货来最优地组合条件异步执行流(或者不可能，因为每个请求的延迟在运行时都
浏览 6提问于2016-02-11得票数 258
回答已采纳
1回答
如果一个方法在线程工具线程上运行，并且它正在等待另一个方法，那么它是否会在等待期间返回到线程池，以便它可能执行另一个任务？
浏览 2提问于2019-11-14得票数 0
回答已采纳
3回答
在主线程中运行流
、、
再次，我将RxJava与Java9流进行比较。我看到默认情况下流是异步的，我想知道是否有一种方法可以使它同步运行。
有时，我们只是想要使用它不是用于Nio，而是用于糖语法，并且有一个更一致的代码。
默认情况下，在RxJava中它是同步的，您可以使用管道中的observerOn和subscribeOn异步运行它。
在流中有什么操作人员让它在主线程中运行？
致以问候。
浏览 1提问于2017-09-30得票数 5
回答已采纳
我想要写一个线程池，它能够处理Runnable。那些运行表的执行时间是不可预测的，但是响应性应该尽可能高。为了实现这一点，我希望监视是否有运行程序需要很长时间才能执行。这些Runnable被认为不像其他Runnable那样重要，因此如果有，我希望能够暂停它们，以便在线程上执行另一个更短的Runnable，其中更高级的Runnable在恢复持久Runnable之前和之后被执行。是否可以暂停运行，并将其当前状态保存在Java中，这样我就可以做到这一点了吗？
浏览 3提问于2015-01-07得票数 0
回答已采纳
2回答
我读了一些关于并发性的文章(这让我很头疼)。
我知道您可以从主线程设置一个在EDT上运行的任务，方法是：
SwingUtilities.invokeLater
但是，您可以从EDT设置一个任务在主线程上运行吗？
如下所示：
Thread mymainthread=Thread.currentThread();//<referring to the thread that initially kicks off public static void main
public void mousePressed(MouseEvent e){ //queue a task to run on
浏览 6提问于2012-11-04得票数 2
2回答
在工作了一段时间后，注意到即使你产生了1000个任务，它们也不会立即开始。基本上，即使我启动了1000个任务，其中100个在运行，900个在等待运行。
所以我的问题是，他们是如何开始的？.net如何确定何时开始运行任务或使其等待运行？我可以遵循什么方法来立即启动它们？我想让一定数量的任务/线程一直在运行。
如果我使用线程而不是任务，它们会立即开始运行，还是.net会根据需要启动它们？
问题可能不是很清楚，所以请让我澄清。
基本上我产生了1000个(保持这个数字的产生。当一个任务完成时启动另一个任务)任务，但其中只有125个任务是Running的，875个任务是WaitingToRun :)
这
浏览 0提问于2013-03-03得票数 2
回答已采纳
1回答
将多个可观测数据连接到一个源
、、、、
我有很多不同类型的网络调用，比如字符串、int等等。
我在试着让它们平行。
在官方的rxjava文档中，我们可以读到：
Flowable.range(1, 10)
.parallel()
.runOn(Schedulers.computation())
.map(v -> v * v)
.sequential()
.blockingSubscribe(System.out::println);
这个例子很简单，因为我们的所有类型都是Int。但是，如果我们有不同的类型，例如字符串、布尔、Int，该如何做呢？
这个5的每个调用都是independentgroup，这5个调
浏览 3提问于2020-12-28得票数 0
我已经成为java 8中的函数式编程以及Rx java的铁杆粉丝。但一位同事最近指出，使用这些工具会影响性能。所以决定运行JMH基准测试，但看起来他是对的。无论我做什么，我都不能让streams版本提供更好的性能。下面是我的代码
@OutputTimeUnit(TimeUnit.NANOSECONDS)
@BenchmarkMode(Mode.AverageTime)
@OperationsPerInvocation(StreamVsVanilla.N)
public class StreamVsVanilla {
public static final int N = 10000;
浏览 12提问于2017-12-30得票数 5
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
