如何实现期货组合
期货组合是指通过同时买入或卖出多个期货合约来实现投资目标的策略。实现期货组合可以通过以下几种方式：
- 多头组合：多头组合是指通过买入多个期货合约来实现投资目标。多头组合可以用于看涨市场，投资者预期价格上涨。例如，投资者可以同时买入多个不同到期日的期货合约，以分散风险并获得更大的收益机会。
- 空头组合：空头组合是指通过卖出多个期货合约来实现投资目标。空头组合可以用于看跌市场，投资者预期价格下跌。例如，投资者可以同时卖出多个不同到期日的期货合约，以分散风险并获得更大的收益机会。
- 套利组合：套利组合是指通过同时进行多个相互关联的期货合约的买卖来实现风险无套利收益。套利组合可以利用不同市场、不同合约或不同到期日之间的价格差异来获取利润。例如，投资者可以同时买入一个市场的期货合约，同时卖出另一个市场的期货合约，以获得价格差异带来的利润。
- Delta中性组合：Delta中性组合是指通过同时进行多个期货合约的买卖来实现对冲风险的目标。Delta是期权的价格变动与标的资产价格变动之间的关系。通过组合多个期货合约，投资者可以实现对冲风险的效果。例如，投资者可以同时买入一个期货合约，同时卖出另一个期货合约，以对冲标的资产价格波动带来的风险。
腾讯云提供了一系列云计算产品和服务，可以支持期货组合的实现。以下是一些相关产品和服务：
- 云服务器（ECS）：腾讯云的云服务器提供了可扩展的计算能力，可以满足期货组合的计算需求。了解更多：云服务器产品介绍
- 云数据库（CDB）：腾讯云的云数据库提供了高可用、可扩展的数据库服务，可以存储和管理期货组合的相关数据。了解更多：云数据库产品介绍
- 云存储（COS）：腾讯云的云存储提供了安全可靠的对象存储服务，可以存储期货组合的相关文件和数据。了解更多：云存储产品介绍
- 人工智能（AI）：腾讯云的人工智能服务可以用于期货组合的数据分析和预测。例如，可以使用腾讯云的机器学习平台进行期货价格的预测和模型训练。了解更多：人工智能产品介绍
请注意，以上仅为腾讯云的一些产品和服务示例，其他云计算品牌商也提供类似的产品和服务，可以根据实际需求选择适合的解决方案。
相关·内容
我已经启动了一个在Scala上编写异步PostgreSQL驱动程序的项目，要成为异步的，我需要接受回调并使用将来，但是接受回调和未来会使代码变得很麻烦，因为您总是必须发送回调，即使它是无用的。
下面是一个测试：
"insert a row in the database" in {
withHandler {
(handler, future) =>
future.get(5, TimeUnit.SECONDS)
handler.sendQuery( this.create ){ query => }.get( 5, Time
浏览 0提问于2012-03-10得票数 3
回答已采纳
2回答
如何合并多个FutureTask，以便在同一个响应中为所有人获得回调。
我们使用Future<T>就像
Future<String> getData(int duration) async {
await Future.delayed(Duration(seconds: duration)); //Mock delay
return "This a test data for duration $duration";
}
调用上述方法，如getData(2).then((value) => print(value));
如果我们想要调用多个
浏览 3提问于2020-07-04得票数 10
回答已采纳
1回答
我刚刚从Akka开始，我试图把一些杂乱无章的功能分割成更易于管理的部分，每个部分都由不同的演员来完成。
我的任务似乎完全适合这个演员模型。我有一个对象树，它们保存在数据库中。每个节点都有一些属性；让我们专注于一个节点，并将其称为财富。孩子们的财富取决于父母的财富。当计算节点上的财富时，这应该会在子节点上触发类似的计算。我希望收集所有更新的节点实例，并将它们同时保存在DB中。
这似乎很简单:一个参与者只执行计算，然后为当前节点的每个子节点启动另一个参与者。当所有子节点返回一条带有计算结果的消息时，参与者收集它们，添加当前节点并向其上方的参与者发送一条消息。
问题是，我不知道如何确保一个人收到了来
浏览 4提问于2012-10-09得票数 3
回答已采纳
看过演示文稿后，我很好奇地想知道Akka实现的期货和代理带来了哪些额外的功能。
浏览 0提问于2013-05-02得票数 3
回答已采纳
1回答
我在想，Future是如何被评估的？我的意思是，如果我们有命令式编程，我们从A点执行程序到B点，然后在它们之间的某个地方创建一个Future，当它完成后，将结果打印到控制台。我们的程序是如何使这一步在流程中打印出来的？
浏览 2提问于2014-05-21得票数 0
1回答
如何同步大量嵌套生产者-消费者的总体消费者完成？
例如，假设您有一个"USPS“系统实现：
运行一个Backoffice.start函数，它在我的SubOffice对象中启动一个可运行的SubOffice.startMailProcessing
我所有的SubOffice对象使用者“开始”功能现在开始处理邮件。
然后，每个SubOffice对象对消费者进行自己的扇形，从而启动一个Runnable of MailTruck.deliverMail
等待所有上述邮件流程处理当天的邮件，等待所有卡车发送邮件
重复
我可以设想出几种解决方案：
似乎有一种方法是s
浏览 4提问于2017-11-06得票数 1
我正在尝试编写一个角色层次结构，用于并行查找介于0和5之间的数字。
下面是我的代码：
import akka.actor.{Actor, ActorSystem, Props}
import akka.pattern.ask
import akka.util.Timeout
import scala.concurrent.Await
import scala.concurrent.duration.DurationInt
import scala.language.postfixOps
class A1 extends Actor {
override def receive = {
浏览 2提问于2021-03-23得票数 0
1回答
我有个这样的场景。
MainClass
event.addListener(Event e){
if (e == EXPECTED_EVENT)
Future<?> result = executorService.submit(myTask);
}
}
doSomething()
doSomethingElse()
doMoreStuff()
如果其中一项任务失败，是否有任何方法中断主流？
我不知道在哪里以及如何准确地同步异常部分：
try {
Object result = ((Future<?>) expectedFu
浏览 1提问于2015-11-29得票数 0
回答已采纳
Hi，I‘m研究Scala未来和获取内部数据的方法在未来/Promises.So中是扭曲的，所以我编写了我所知道的所有模型，以获取Scala期货的内部数据。
我们总是看到这两种情况：
有一段时间，我们在异步函数的块中获取未来的内部数据，如map、flatMap、foreach、折叠、.
2-有一段时间，我们在未来中获得了结果，比如使用等待
在本例中，我使用Akka ?或ask函数(它的异步)，并尝试了解如何获得未来结果的最佳实践
1-走出街区？
2-进入街区？
当我们异步时，我们知道阻塞是不好的做法(所以使用Await，Sleep，.)都是坏的。
请帮助我找到替代Await或Fut
浏览 1提问于2018-04-19得票数 2
例如，Folly支持可在中找到的非阻塞组合器collectN
它没有提供一个非阻塞的组合器collectNWithoutException，它只会收集类似于collectAny的成功的未来，但不只是一个结果的未来。
Scala似乎只提供了firstCompletedOf，这将是带有n个== 1的collectN。
如果Scala不支持这些非阻塞组合子，我该如何轻松地实现它们呢？我想使用现有的组合子来实现。
浏览 1提问于2018-09-19得票数 4
我是scala的新手，我一直致力于理解语法，这样我才能更有效率。从功能语法和scala成语来看，这看上去如何？
特别是，我想知道这是否是一种处理期货的好方法。我知道onComplete、onSuccess等.匹配，但是我很难把返回值拿回来。地图似乎是正确的方法。
object Application extends Controller with securesocial.core.SecureSocial {
val inboxSlurper = Akka.system.actorOf(Props[InboxSlurper], name = "inboxSlurper"
浏览 0提问于2013-10-25得票数 4
回答已采纳
2回答
void process(String question){
Callable<ResponseList> callable1 = () -> this.stsCompute question);
Future<ResponseList>task1 = executorService.submit(callable1);
Callable<ResponseList> callable2 = () -> this.dssmCo
浏览 0提问于2018-11-03得票数 1
回答已采纳
我正在寻找规范代码，以将番石榴的替换为Java 8的CompletableFuture代码。
我认为似乎是的替代品，但我没有看到任何类似于successfulAsList()的东西。
浏览 5提问于2017-04-10得票数 6
回答已采纳
1回答
当我在单个页面中执行多个未来的http请求时，我想问一下提高性能的问题。以防万一，我想要构建一个仪表板页面。在仪表板中，我有4个端点url，它们在每个端点中返回不同的结果，应该在仪表板页面中显示。
这里是加载数据时的示例代码
var client = new http.Client();
Future main() async {
var newProducts = await client.get("${endpoint}/product?type=newly&limit=5");
ProductListResponse newProductRespon
浏览 0提问于2019-11-24得票数 0
回答已采纳
1回答
如何在Seq上执行减/折叠操作，然后得到最后的值。
我正在执行一个返回未来的操作(在本例中是Redis调用)。我正在使用地图操作处理未来(结果)。
映射操作返回Future[SeqAny]类型。
res0: scala.concurrent.Future[Seq[Any]] = scala.concurrent.impl.Promise$DefaultPromise@269f8f79
现在，我想在这个Seq上执行一些操作(折叠/减少)，然后得到一个最终的值。我怎样才能做到这一点？
implicit val akkaSystem = akka.actor.ActorSystem()
va
浏览 2提问于2014-04-14得票数 0
回答已采纳
我有三个类:用户，帖子和评论。用户有许多帖子和Posts有许多注释。
我希望在调用小部件的构建方法之前获取所有数据。
我尝试使用initState()来完成以下操作：
class FetchDataExample extends StatefulWidget {
final User _user;
FetchDataExample(this._user);
@override
_State createState() => _State(_user);
}
class _State extends State<FetchDataExample> {
浏览 0提问于2019-07-31得票数 1
我需要一些未来的时间来等待Python/Django中的其他人，我不得不使用来自网络和concurrent.futures的源代码(backport到2.7)黑出我自己的“诺言”类。
这是我的代码(不是很漂亮，但完全符合我的需要)，我大部分的想法都是从博客上得到的(我现在找不到它的链接了……将于稍后更新)：
class Promise(object):
def __init__(self, func):
self.func = func
LOG.debug('Create Promise from callable %s %s' % (f
浏览 1提问于2013-12-19得票数 4
回答已采纳
有两个可完成的期货cf1和cf2定义如下：
CompletableFuture<Boolean> cf1 = CompletableFuture.completedFuture(true);
CompletableFuture<Boolean> cf2 = CompletableFuture.completedFuture(true);
从技术上讲，可以这样做：
var result1 = cf1.get();
var result2 = cf2.get();
assertThat(result1).isEqualTo(result2);
例如，如果只有一个未来，我
浏览 16提问于2022-09-16得票数 1
回答已采纳
2回答
是它们的任意方式，这样我就可以使用多线程概念并行调用执行，并使创建的@RestController的执行速度更快，它将接受String和List<MultipartFile>作为请求参数，而这里的代码正在工作--如果我要通过for循环解析一个又一个文件的话。执行死刑所需的时间更长。
以下是主计长
@RequestMapping(value = "/csvUpload", method = RequestMethod.POST)
public List<String> csvUpload(@RequestParam String paren
浏览 0提问于2019-02-27得票数 3
回答已采纳
1回答
我决定使用超级创建来构建一个读取POST方法的正文数据的服务器。解释了我正在寻找的部分内容，但我不想使用tokio::run或future::lazy，因为根据我的理解，超级使用Tokio和期货，而超级体返回流。我想要完成的是找到处理流的其他方法，并获得更多关于超Request方法的知识。
在第一种方法中，我concat2然后调用wait。wait阻塞当前线程，因此我的代码挂起。
if Method::POST == req.method() {
let body = req.into_body().concat2().wait();
// convert to json an
浏览 3提问于2019-10-07得票数 0
回答已采纳
我需要同时执行数千个任务。因此，我正在考虑使用Futures来实现这一目的。但这数千项任务中的每一项都已经在未来了。在未来中使用未来是好的吗？或者我在这里做错了什么。每个任务大约需要1毫秒的计算时间。因此，与其按顺序执行它们，我认为在期货中执行是更可取的。所以从理论上讲，完成整个任务大约需要1毫秒左右的时间。但是完整的执行需要150毫秒。因此，这是否意味着所有并行任务都比单独执行的任务占用更多。
val start = System.nanoTime()
浏览 2提问于2016-07-04得票数 0
当谈到期货和回调时，说
Vert.x核心API基于回调来通知异步事件。经验丰富的开发人员自然会认为，这为所谓的“回调地狱”打开了大门，在这种情况下，多层嵌套回调使代码难以理解，如以下虚构代码所示：
foo.a(1, res1 -> {
if (res1.succeeded()) {
bar.b("abc", 1, res2 -> {
if (res.succeeded()) {
baz.c(res3 -> {
dosomething(res1, res2, res3, res4 ->
浏览 3提问于2020-06-11得票数 3
回答已采纳
我的代码排列如下：
let done = client_a.
.get_future(data)
.then(move |result| {
// further processing on result
spawn a future here.
});
tokio::run(done);
现在我有了另一个未来，我想和“结果的处理”一起来处理这个结果。然而，这一未来完全独立于client_a，这意味着：
两者都可能有不同的错误类型。
一个人的失败不应该阻止另一个人。
让done = client_a. .get_future(数
浏览 2提问于2019-09-21得票数 0
回答已采纳
2回答
假设一些期货存储在一个Vec中，它的长度是由运行时决定的，你应该并发地加入这些期货，你该怎么办？ 显然，通过tokio::join文档中的示例，手动指定Vec的每个长度可以是1，2，3，...处理一个值得尊敬的案例应该是可行的。 extern crate tokio;
let v = Vec::new();
v.push(future_1);
// directly or indirectly you push many futures to the vector
v.push(future_N);
// to join these futures concurrently one
浏览 98提问于2020-08-26得票数 8
回答已采纳
1回答
我对vertx和异步编程很陌生。
我有两个眩晕通过事件总线通信，如下所示：
//API垂直线
public class SearchAPIVerticle extends AbstractVerticle {
public static final String GET_USEARCH_DOCS = "get.usearch.docs";
@Autowired
private Integer defaultPort;
private void sendSearchReque
浏览 13提问于2022-05-20得票数 0
1回答
并发概述
、、
Scala提供了一个很好的套件来处理并发(Akka，并行收集，期货等等)，这也让我有点困惑。什么时候使用什么有什么指引？某种最佳做法？
浏览 3提问于2013-11-12得票数 5
回答已采纳
对于在Rust中异步调度和执行的“就绪”方法，我有一个疑问，因为它与基于运行时语言的“完成”方法(Python，Node.js)有关。我使用的是“就绪”和“完成”，这是的术语引发了这个问题。
如果我得到的是正确的，锈蚀期货(如std-futures)在“准备状态”方法下实现：
包装在任务内部，将封装的未来的私有调用堆栈存储在内存中，以允许其中断和恢复，假设其他期货在间隔内运行；
由于一些i/o参与者调用任务(通过任务已针对相关的i/o参与者注册的回调)，他们对包装任务进行了轮询；
当任务链中的所有其他任务或任务链中的i/o参与者都已注册回调时才返回值，而这些任务或I/O参与者由于他
浏览 5提问于2020-04-26得票数 2
回答已采纳
2回答
当一个函数依赖于一些未来的结果时，我一次又一次地挣扎。这通常归结为未来[Seq[FutureMyObject]]这样的结果。
为了消除这个问题，我现在在一个助手函数中使用Await来获取一个非未来的对象，并减少嵌套。
看上去像这样
def findAll(page: Int, perPage: Int): Future[Seq[Idea]] = {
val ideas: Future[Seq[Idea]] = collection.find(Json.obj())
// [...]
ideas.map(_.map { // UGLY?
idea =>
浏览 4提问于2013-11-29得票数 22
回答已采纳
1回答
我有测试脚本
(defn foo [] ( print "OK!" ))
(print "main")
(future-call foo)
(print "end")
当我在REPL中运行它时，总是很好
user=> (defn foo [] ( print "OK!" ))
#'user/foo
user=> (print "main")
mainnil
user=> (future-call foo)
OK!#<core$future_call$reify__6320@1d499
浏览 0提问于2015-07-24得票数 1
回答已采纳
我正在学习python并发性，并且我被介绍了未来的概念。我读到as_completed()接受了一个可迭代的未来，并在他们完成的时候产生它们。
我想知道它是如何在内部工作的。它是否立即产生完成的任务(未来)？一种天真的方法是迭代所有的未来，并使用done()检查每个未来，但这是低效的。
那么这个函数背后的魔力是什么呢？
谢谢!
浏览 2提问于2018-07-09得票数 21
回答已采纳
1回答
有没有一种不需要管理自己的线程就可以用Jsch进行异步sftp文件传输的方法？
我看到有一个来监视进度，但它只是提供了一个回调。
我正在寻找类似于Java的AsynchronousFileChannel编写方法的东西：
哪个库提供异步sftp传输？
浏览 0提问于2017-05-11得票数 0
回答已采纳
3回答
给定以下两个类型为Future[Int]的方法
scala> import scala.concurrent._
import scala.concurrent._
scala> import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.ExecutionContext.Implicits.global
scala> def g: Future[Int] = Future { Thread.sleep(5000); 100 }
g: scala.concurrent.
浏览 2提问于2015-02-27得票数 1
1回答
试图在新tokio线程中调用异步函数会导致某些函数出错。
在这个最小的例子中，板条箱，tokio和iota-流被使用。方法send_announce()是异步的，并返回一个地址。等待此方法将导致编译错误，说明未实现std::Marker::Send特点
dyn std::future::Future<Output = Result<GenericMessage<TangleAddress, BinaryBody>, iota_streams::iota_streams_core::Error>>
dyn std::future::Future<Outp
浏览 11提问于2022-02-23得票数 0
回答已采纳
我有这样一个简单的代码来模拟异步代码在阻塞操作中的工作方式。
我期待所有这些“你好”打印将显示在1000毫秒后。
但是这段代码的工作方式就像一个普通的阻塞代码，每个hello_wait调用等待1000 and，并在1000 and之后打印另一个Hello。
如何使它同时运行？
use std::{time::Duration};
use async_std::task;
async fn hello_wait(){
task::sleep(Duration::from_millis(1000)).await;
println!("Hello");
}
#[a
浏览 4提问于2021-11-16得票数 2
回答已采纳
2回答
我有一堆期货可以在非常不同的时间完成，就像这样：
val results = task.getAssignedFiles map {
file: File => Future[Result] {
<heavy computation>
}
}
现在，我想在一个输入期货完成后立即遍历results，基本上在结果中轮询所有的期货，直到完成，做一些处理，然后继续，直到所有这些都完成为止。类似于：
while (!results.allCompleted) {
one = results.firstCompletedFuture
process(one)
}
浏览 2提问于2016-11-25得票数 0
回答已采纳
在Python中，我通常会使用标准库中的队列(这是线程安全的)，并编写一个函数来使用队列中的url，并将下载的内容保存到磁盘上。我会在threading.Threads中产生一些这样的函数。如果下载失败，我会再次将相同的url放入队列中。
用Scala编写一个类似的并发下载器的惯用方法是什么？我应该使用哪些抽象？
浏览 2提问于2016-08-11得票数 1
1回答
据我所知，诺言返回未来，数据流也返回未来，我相信数据流是对承诺的抽象，是当它所依赖的值变为可用时触发的。数据流是否像承诺的图形结构？有人能解释一下这件事吗？
浏览 2提问于2014-08-21得票数 1
回答已采纳
1回答
如我所知(如果我错过smth)，当我们使用Spring MVC应用程序时，我们有一个来自服务器的线程池(Tomcat.)当请求来自池处理请求时，有时会很糟糕，因为如果任务需要很长时间我们的线程将一直处于繁忙状态，为了避免这种行为，我们可以将控制器的返回类型从String更改为Callable<String>或DefferedResult<String>，现在tomcat中的worker线程可以从ExecutorService执行到线程(我们在@Configuration类中配置)，更好的原因是tomcat线程可以处理其他请求，不会等待每个请求的执行。但我不明白WebFl
浏览 1提问于2018-03-18得票数 2
回答已采纳
1回答
我得到了错误
found : scala.concurrent.Future[Option[models.ProcessTemplatesModel]]
required: Option[models.ProcessTemplatesModel]
我的职能如下
def createCopyOfProcessTemplate(processTemplateId: Int): Future[Option[ProcessTemplatesModel]] = {
val action = processTemplates.filter(_.id === processTemplateId)
浏览 3提问于2017-06-07得票数 1
回答已采纳
1回答
REST调用使用spray.io。它使用各种函数验证调用中的请求，其中包括查询数据存储的中间函数。如果一切正常，则写到所述数据存储区。在这种情况下，最多有4个IO操作: HTTP请求、数据读取、数据写入和HTTP响应。如果我决定使用IO monad，那么如果我有一些可能或不需要的IO (例如，如果一些验证失败了就不需要进行读写操作)，那么我将如何构造执行IO呢？想必，首先，我可以先忽略喷雾剂的东西，并认为评估是从喷雾完成后开始的。但是如何将IO函数与非IO函数组合起来呢？我一定要把那些非伊奥的东西搬到单桅帆船上吗？
浏览 3提问于2014-05-08得票数 0
回答已采纳
我想将用户的请求数据附加到actix-web中的过氧化响应中，但会发生type mismatch resolving错误。 我想这是关于生锈期货的，但我不知道这个问题，我该如何解决它。 示例代码： use actix_web::*;
use futures::future::ok;
use futures::Future;
fn show_request(
request: &actix_web::HttpRequest,
) -> Box<Future<Item = HttpResponse, Error = Error>> {
le
浏览 24提问于2019-01-22得票数 1
回答已采纳
2回答
我试图理解何时使用，并发现比主要的Akka文档更有帮助。所以看起来阿克卡期货公司做的事情和完全一样。所以我问：
在参与者系统之外，Akka期货对Java期货有什么好处？什么时候使用每一个？
在演员系统的背景下，为什么要使用Akka未来？不是所有参与者之间的消息都是异步的、并发的和非阻塞的吗？
浏览 5提问于2015-06-04得票数 16
回答已采纳
1回答
我有两个用Kotlin Vert.x编写的Hello World句柄方法。我想清楚地了解他们是如何工作的，如果可能的话。一个是AsyncVertilce，另一个是CompositeVerticle。
这是Hello World协程异步垂直句柄方法。
var result = async {
callFunctionAwait(
getDependentAddress(HELLO_WORLD), message.headers(), message.body(), messageMarker
)
}
var res
浏览 8提问于2021-10-24得票数 0
1回答
我没有在实践中使用Finagle或Akka，但我读了很多关于它们的文章。
Finagle是一个RPC系统，Akka是一个高度并发的应用程序工具包，为什么所有的人都把它们作为两种不能一起使用的解决方案来比较呢？我做过的所有搜索都建议使用一种或另一种，没有人提议将它们一起使用。
例如，Finagle有一种非常有趣的方法，可以通过thrift及其IDL定义端点。使用这个IDL，我们可以定义一个自定义端点，并通过scooge或任何代码生成工具，可以不费任何力气就可以得到一个服务。另外，一个连接到此服务的客户端是用许多常见的客户端问题自动解决的(重连接、超时、重试、负载平衡、连接池、.)。
相反，Akk
浏览 3提问于2013-12-01得票数 18
回答已采纳
2回答
假设以下场景:一个小部件显示一个“加载”屏幕，直到异步回调完成，然后切换到另一个小部件。
我正在试着测试它，特别是显示“加载”屏幕的部分。因此，我尝试的是模拟异步回调，并将其设置为类似于Future.delayed(Duration(days: 1))的内容，这样我就可以确保它永远不会在特定的测试中完成。
这似乎是可行的，但接着颤栗对我的愤怒，并报告有关等待定时器的问题。由于某种原因，所有计时器都必须完成测试才能成功完成测试。
那么，如何以正确的方式编写这个测试用例呢？我怎样才能创造一个永远不会结束，也不会遇到计时器问题的未来？
浏览 3提问于2022-04-03得票数 1
回答已采纳
我有以下内容：
private JobInfo aggregateJobInfo() {
final JobsResult jobsResult = restClient().getJobs();
final List<String> jobIds = extractJobIds(jobsResult);
//fetch details, exceptions and config for each job
final List<JobDetails> jobDetails = jobIds.stream().map(jobId -&g
浏览 0提问于2016-06-26得票数 3
回答已采纳
将get方法与Future类分离(我希望它驻留在这个类中)并迫使编码器必须知道这个名为Await的外部两种方法类，有什么特别的优势吗？
浏览 5提问于2016-07-01得票数 11
回答已采纳
2回答
子类化未来类
、、
我想子类模块的concurrent类。
医生：
未来类封装了可调用的异步执行。未来的实例由Executor.submit()创建。
Executor的文档没有解释它从哪里提取Future类。
..。如何使Executor.submit()强制我的自定义未来类？
为什么我需要它？
我喜欢OOP，因为它创建了可读的代码。我希望结果是这样的：
for my_future in concurrent.futures.as_completed(...):
my_future.my_custom_method()
浏览 2提问于2016-07-18得票数 4
回答已采纳
2回答
我有以下代码：
for (int i = 0; i < nComp; i++) {
Callable<Long> worker = new WSCaller(compConns[i]);
col.add(worker);
}
List<Future<Long>> results=null;
results = executor.invokeAll(col, timeout, TimeUnit.SECONDS);
for (Future<Long> future : results) {
if ( !future.i
浏览 1提问于2011-04-16得票数 0
正如标题所示，我有一些奇怪的要求，这就是在上述情况下如何处理异常。
所以我基本上需要做嵌套验证。这些验证中有些是独立于另一些的，有些则不是。如果抛出(Un)选中的异常，则应将其传播到最多的调用方。通过传播和最多调用，我指的是控制器层，这样ControllerAdvice就可以启动。
以下是一些代码：
我们有一个基本控制器，它是异步函数的“顶层”调用者。
@RestController @RequestMapping("/test") @AllArgsConstructor公共类控制器{
私有最终助手；公共字符串测试(字符串代码，字符串系统)抛出ExecutionExceptio
浏览 5提问于2021-10-22得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
