如何将缓存API与futures一起使用
缓存API是一种用于存储和检索数据的技术，它可以提高应用程序的性能和响应速度。而futures是一种并发编程模型，用于处理异步任务和并行计算。将缓存API与futures一起使用可以进一步优化应用程序的性能和并发能力。
在使用缓存API与futures的组合时，可以按照以下步骤进行操作：
- 引入缓存API库：根据所使用的编程语言和框架，选择合适的缓存API库。常见的缓存API库有Redis、Memcached等。这些库提供了丰富的功能和接口，可以方便地进行数据存储和检索。
- 初始化缓存连接：在应用程序启动时，需要初始化与缓存API的连接。这包括设置连接参数、建立连接、验证连接等操作。通过缓存连接，应用程序可以与缓存服务器进行通信。
- 缓存数据：在需要缓存数据的地方，可以使用缓存API提供的接口将数据存储到缓存中。通常，缓存数据可以使用键值对的形式进行存储，其中键用于唯一标识数据，值则是要存储的数据本身。
- 检索数据：在需要检索数据的地方，可以使用缓存API提供的接口从缓存中获取数据。通过提前缓存数据，可以避免频繁地访问数据库或其他资源，从而提高应用程序的响应速度和性能。
- 使用futures进行并发处理：在需要处理大量并发任务的地方，可以使用futures模型进行并发处理。通过将任务封装成futures对象，可以异步执行任务，并在需要时获取任务的结果。这样可以充分利用系统资源，提高应用程序的并发能力。
缓存API与futures的组合可以应用于各种场景，例如：
- Web应用程序：可以将常用的页面片段、数据库查询结果等缓存起来，提高页面加载速度和用户体验。
- 并发任务处理：可以将大量的计算任务分解成小任务，并使用futures进行并发处理，提高计算效率。
- 数据分析：可以将中间结果缓存起来，避免重复计算，加快数据分析的速度。
对于腾讯云的相关产品和服务，可以考虑使用腾讯云的云缓存Redis、云数据库CDB、云服务器CVM等产品。这些产品提供了稳定可靠的云计算基础设施，可以与缓存API和futures结合使用，提供高性能和可扩展的解决方案。
腾讯云云缓存Redis产品介绍链接地址：https://cloud.tencent.com/product/redis
腾讯云云数据库CDB产品介绍链接地址：https://cloud.tencent.com/product/cdb
腾讯云云服务器CVM产品介绍链接地址：https://cloud.tencent.com/product/cvm
相关·内容
我的java应用程序正在执行两个任务。在pub-sub上监听新消息并创建云任务。此外，它使用默认的计算服务帐户，该帐户分配了所有角色。现在，我们使用具有以下作用域的默认服务帐户运行计算实例。
serviceAccounts:
- email: ***********-compute@developer.gserviceaccount.com
scopes:
- https://www.googleapis.com/auth/devstorage.read_only
- https://www.googleapis.com/auth/logging.write
- https:/
浏览 0提问于2021-03-08得票数 1
1回答
使用Spring的缓存抽象，我如何让缓存异步刷新条目，同时仍然返回旧条目？
我正在尝试使用Spring的缓存抽象来创建一个缓存系统，在这个系统中，在相对较短的“软”超时之后，缓存条目可以进行刷新。然后，当它们被查询时，返回缓存的值，并启动异步更新操作来刷新条目。我也会
Guava的缓存构建器允许我指定缓存中的条目应该在一段时间后刷新。然后，缓存加载器的reload()方法可以被异步实现覆盖，允许返回过时的缓存值，直到检索到新的缓存值。然而，spring缓存似乎没有使用底层Guava缓存的CacheLoader
是否可以使用Spring的缓存抽象进行这种异步缓存刷新？
编辑以澄清:使用Guava
浏览 0提问于2015-06-03得票数 10
1回答
我想要一个处理一些流的结构。所有流共享同一项。逻辑如下:我需要创建一个唯一的流，其中包含来自所有其他流的所有项。我还需要在“主”流中添加“新”流。我不在乎下一个项目来自哪个流。
为此，我看到有一个函数应该执行上面描述的逻辑。
pub struct WsPool {
merge: Arc<Mutex<SelectAll<Box<dyn Stream<Item=MyItem> + Send + 'static>>>>,
}
impl WsPool {
pub fn new() -> Self {
浏览 3提问于2021-10-10得票数 1
回答已采纳
我如何设计一个API来隐藏AJAX和HTTP请求的异步本质，或者基本上延迟它以提供一个流畅的界面。下面是推特新的应用程序接口的一个例子：
// get @ded's first 20 statuses, filter only the tweets that
// mention photography, and render each into an HTML element
T.User.find('ded').timeline().first(20).filter(filterer).each(function(status) {
$('div#t
浏览 0提问于2010-05-09得票数 19
回答已采纳
为了澄清这一问题的原因：
使用两个相同名称的模块是令人困惑的。它们所代表的是什么使它们与众不同？
哪一项任务能解决另一项不能解决的问题，反之亦然？
浏览 2提问于2015-04-27得票数 54
回答已采纳
我正在制作一个在ProcessPoolExecutor中运行进程并在完成后返回结果的程序。我想运行的脚本使用的是非常老的库，所以我不想将它们包含在主脚本中。相反，我有另一个虚拟环境，它被设置为运行子进程。
我正在使用一个ProcessPoolExecutor来生成这些工作。在运行这些作业时，如何选择要使用的python解释器？
我看到ProcessPoolExecutor有一个initargs参数，但是当我将它包含在代码中时：
with concurrent.futures.ProcessPoolExecutor(
initargs=('PYTHONHOME',
浏览 3提问于2021-11-29得票数 1
回答已采纳
2回答
如果我在主线程中执行ExecutorService.shutdownNow()，它不会停止所有线程，但如果我在Thread1或Thread2中执行ExecutorService.shutdownNow()，它会杀死它的子线程，如何将关闭命令级联到最低级别？
Main thread
/ \
/ \
Thread 1 Thread 2
| | | | |
A B C D E
如何杀死主线程中的所有线程？
使用下面的代码片段来抓取线程
CompletionService<Objec
浏览 1提问于2016-06-17得票数 1
1回答
我在df中有一个IP地址列表。这些IP地址在GET请求中使用requests发送到ARIN数据库，我感兴趣的是获取该IP地址的组织或客户。我正在使用requests Session()在requests-futures FuturesSession()中，希望能加快API调用的速度。以下是代码：
s = requests.Session()
session = FuturesSession(session=s, max_workers=10)
def getIPAddressOrganization(IP_Address):
url = 'https://whois.arin
浏览 3提问于2018-01-18得票数 3
1回答
我正在尝试理解如何缓存来自应用程序接口(准确地说是PokeAPI)的数据，以限制应用程序对数据进行的调用量。
例如，我的一个函数从API获取"All Pokemon“：
function getAllPokemon() {
$url = 'http://pokeapi.co/api/v2/pokemon/?limit=151';
$response = Requests::get($url);
$allPokemonData = json_decode($response->body, true);
return
浏览 0提问于2017-10-05得票数 0
我使用的是sp_BlitzCache，它非常有用，我运行了以下命令：
Sp_BlitzCache @SortOrder = 'duration';
GO
当我发现持续时间最长的查询时，您如何将查询与SPID联系起来？这样我就知道罪魁祸首了
浏览 0提问于2021-09-16得票数 0
1回答
if __name__ == '__main__':
MATCH_ID = str(doc_ref2.id)
MATCH_ID_TEAM = doc_ref3.id
with concurrent.futures.ProcessPoolExecutor(max_workers=30) as executor:
results = list(executor.map(ESPNlayerFree, teamList1))
MATCH_ID_TEAM = str(doc_ref4.id)
with concur
浏览 0提问于2019-11-25得票数 2
2回答
我正在制作一个购物应用程序。在产品中，我给出了从api收到的不同类型产品的几个选项卡。我想添加“所有”的另一个选项卡，它一起显示所有其他选项卡中的所有产品。所有API都是使用每个选项卡标题的id调用的，并且在结构上是相同的。在网上，我可以找到一些关于future.wait的答案，但我不认为它在这种情况下会起作用，因为他们谈论的是一个接一个的任务，这就是我想要的，但我也想把结果结合起来。基本上，如何将所有这些相同的未来组合成一个单一的未来，传递给未来建设者，或者有解决这个问题的办法？
编辑:我得到的期货清单如下：-
for (int i = 0;i <Length;i++) {
Prod
浏览 3提问于2022-04-24得票数 0
回答已采纳
1回答
我正在努力学习如何使用Ray API，并将其与我的code代码进行比较。但是，我不知道如何有效地使用这个(我的机器有16个CPU)。
，我是不是做错了什么？如果不是，为什么Ray要慢得多？
import ray
from joblib import Parallel, delayed
num_cpus = 16
@ray.remote(num_cpus=num_cpus)
def square(x):
return x * x
def square2(x):
return x * x
雷：
%%time
# Launch parallel square tasks.
f
浏览 7提问于2022-11-30得票数 0
我已经设置了一个调度程序和4个工作节点来对csv进行一些处理。csv的尺寸只有300 mb。
df = dd.read_csv('/Downloads/tmpcrnin5ta',assume_missing=True)
df = df.groupby(['col_1','col_2']).agg('mean').reset_index()
df = client.persist(df)
def create_sep_futures(symbol,df):
symbol_df = copy.deepcop
浏览 0提问于2017-11-23得票数 0
回答已采纳
3回答
我们有一个移动应用程序，向用户提供提要。提要REST是在tomcat上实现的，它并行地调用不同的数据源，例如Couchbase、MYSQL来表示内容。以下是简单的代码：
Future<List<CardDTO>> pnrFuture = null;
Future<List<CardDTO>> newsFuture = null;
ExecutionContext ec = ExecutionContexts.fromExecutorService(executor);
final List<CardDTO> combinedDTO
浏览 7提问于2016-01-28得票数 12
回答已采纳
假设我有两个重量级IO阻塞操作，findMatchInSomeDB()和getDetailsFromOtherDB(String objectKey)。此外，我希望它们在后台运行，并使用番石榴期货将它们链接在一起，因为其中一种依赖于另一种的结果(我知道这可以在简单可调用的情况下顺序完成，但为了说明起见，可以保持简单)
下面的consumeChain和consumeChainAsync方法之间有什么实际的或细微的区别吗？
import com.google.common.base.Function;
import com.google.common.util.concurrent.AsyncFu
浏览 0提问于2018-10-27得票数 4
回答已采纳
我最近学到了复合期货。我知道我可以有一个期货列表，当它们全部完成后，compositeFuture处理程序将被调用：
CompositeFuture.all(futures).onComplete(compositeAsync -> {
if (compositeAsync.succeeded()){
Future<CompositeFuture> cf = compositeAsync.result();
} else {
// at least 1 future failed
}
});
我的问题是关于这一行：Fut
浏览 3提问于2021-12-29得票数 0
回答已采纳
我有一个相当复杂的递归函数，它有很多参数(Obara-Saika-Scheme，以防有人想知道)，我想更有效地唤起它。作为第一步，我应用了@functools.lru_cache。作为第二步，我现在希望使用multiprocessing.Pool异步计算输入参数的长列表。
调整并添加我的员工池：
from multiprocessing import Pool
from functools import lru_cache
@lru_cache(maxsize=10)
def fibonacci(n):
print('calculating fibonacci(%i)'
浏览 2提问于2017-04-19得票数 23
我试图发出多个请求异步并获得响应，我使用concurrent.futures来完成这个任务，但是在我的函数中使用current_app (来自flask和我总是得到这样的错误)：
RuntimeError: Working outside of application context.
我不知道怎么解决这个问题。有人能帮忙吗？
以下是我的代码：
run.py：
import concurrent.futures
from flask import current_app
from http_calls import get_price, get_items
def init():
w
浏览 0提问于2018-04-29得票数 11
回答已采纳
1回答
有一个async connect()函数如下所示。
use actix_web::client::Client;
use futures::compat::Future01CompatExt;
use futures::future::{FutureExt, TryFutureExt};
pub async fn connect() {
let request = Client::default().get("https://www.google.com").send();
// compat() converts a v0.1 futures::futur
浏览 0提问于2019-08-28得票数 4
回答已采纳
我有一个java类来处理多线程订阅服务。通过实现可订阅接口，可以将任务提交给服务并定期执行。下面是代码的草图：
import java.util.concurrent.*;
public class Subscribtions {
private ConcurrentMap<Subscribable, Future<?>> futures = new ConcurrentHashMap<Subscribable, Future<?>>();
private ConcurrentMap<Subscribable, Inte
浏览 3提问于2015-11-05得票数 1
回答已采纳
我已经编写了一个函数，用于从Strava的公共API下载活动I。 该函数迭代API页面，收集it，并在从它标识为最后一个页面的页面收集it后停止： import requests
def get_activity_ids():
"""Returns a list of activity ids for the token owner"""
ids = []
params = {
'page':
浏览 17提问于2019-01-19得票数 0
回答已采纳
我有一个缓慢的未来，在跑到完成之前会阻塞1秒。
我尝试使用join组合器，但是复合的未来my_app按顺序执行期货：
#![feature(pin, futures_api, arbitrary_self_types)]
extern crate futures; // v0.3
use futures::prelude::*;
use futures::task::Context;
use std::pin::PinMut;
use std::{thread, time};
use futures::executor::ThreadPoolBuilder;
struct SlowCom
浏览 0提问于2018-09-13得票数 7
回答已采纳
2回答
多线程异常处理空闲资源
、、、、
我试图处理在多线程问题中生成的所有异常，以消除内存泄漏、中断或执行异常(我不想传播它们)和类似的情况。如果我中断线程(Thread.currentThread().interrupt())，下面的finally中是否存在shutdownNow()冗余？
ThreadPoolExecutor service = new ThreadPoolExecutor(coreSize, maxSize);
// do stuff
try {
List<Future<?>> futures = new ArrayList<Future&
浏览 0提问于2018-04-26得票数 4
回答已采纳
1回答
我有一个列表dataframe_chunk，其中包含一个非常大的熊猫的数据块，我想把每一个块写到不同的csv中，并并行地这样做。但是，我看到文件是按顺序写入的，我不知道为什么会这样。下面是代码：
import concurrent.futures as cfu
def write_chunk_to_file(chunk, fpath):
chunk.to_csv(fpath, sep=',', header=False, index=False)
pool = cfu.ThreadPoolExecutor(N_CORES)
futures = []
for i
浏览 2提问于2016-07-19得票数 0
我正在使用TDengine作为时间序列存储引擎.如何将vgroup的复制从2更改为3？在改变的过程中，我应该做还是不做什么？
浏览 0提问于2021-11-20得票数 0
我试图在循环中为PUT请求调用rest。每个呼叫都是一个CompletableFuture。每个api调用都返回一个RoomTypes.RoomType类型的对象。
我想收集不同列表中的响应(成功响应和错误响应)。我怎样才能做到这一点？我确信我不能使用allOf，因为如果任何一个调用都不能更新，它就不会得到所有的结果。
如何记录每个调用的错误/异常？
public void sendRequestsAsync(Map<Integer, List> map1) {
List<CompletableFuture<Void>> comple
浏览 2提问于2018-07-02得票数 20
回答已采纳
1回答
我在python中使用Python Futures Concurrent获取结果的方法之一，当我在单独的文件上尝试它时，它工作得很好，但是当我将它与Flask Api集成时，结果是未定义的，我调试并发现flask api正在返回结果，甚至不需要等待未来完成处理结果。如何在处理结果之前停止它。 我在由flask api调用的函数中的未来代码： with concurrent.futures.ThreadPoolExecutor() as executor:
futures_np1 = [executor.submit(self.get_test_score, data, param)
浏览 13提问于2021-05-06得票数 0
2回答
如果我不想在视图标记中执行此操作，
`<%=Html.RouteLink("Listings", "Listings", new {market = "Austin", state = "Texas", pagenumber = 3 })%>`
在MVC2中创建链接的最佳方法是什么？我有一个用于构建自定义链接的helper，但它所做的一切只是充当RouteLink (或ActionLink)的包装器。我想要一个更优雅，语法更短的东西。如果我在控制器中构建链接，如何将其推送到视图中？通过ViewData？(希望不是)
浏览 0提问于2010-08-07得票数 2
回答已采纳
在我们的应用程序中，我试图使用图资源管理器使用以下图形API：
派生结果集的逻辑是什么？例如，API是否查看了我的：
电子邮件活动
Skype列表
Office Delve
AAD用户
我的经理/跳级经理指示
另外，如果我通过更改top参数来检索结果，那么检索结果的逻辑是什么：
$top=10
vs
$top=50
浏览 0提问于2016-10-04得票数 0
我的旧代码看起来像下面这样，所有的db调用都是阻塞的。
我需要帮助将此转换为使用Futures。
def getUserPoints(username: String): Option[Long]
db.getUserPoints(username) match {
case Some(userPoints) => Some(userPoints.total)
case None => {
if (db.getSomething("abc").isEmpty) {
db.
浏览 3提问于2016-10-21得票数 1
我有一个函数f()，它进行API调用，我想异步多次调用它。我这样使用asyncio库：
async def main():
loop = asyncio.get_event_loop()
futures = [loop.run_in_executor(None, f) for i in range(10)]
await asyncio.gather(*futures)
return futures
result = asyncio.get_event_loop().run_until_complete(main())
问题是，有时f()会引发一个Excepti
浏览 0提问于2019-01-03得票数 5
回答已采纳
1回答
我不太了解Python，我正在尝试用Python为Binance Futures制作一个机器人。我遇到了这个错误： client.futures_create_order()(
TypeError: futures_create_order() missing 1 required positional argument: 'self' 下面是我的代码： import ccxt
from binance.client import Client
client = Client("api key", "api secret")
client
浏览 15提问于2021-04-16得票数 1
1回答
我有4个API，我想在一个带有16 an和8个CPU的AWS盒上并行运行。我可以使用python的烧瓶并行运行这些API吗？
基本上，我希望其中一个API接受用户输入，然后并行地查询其他3个API。
我对API和并行处理的范式很陌生，因此任何帮助都将受到高度赞赏。
以下是我的想法：
import requests
r1 = requests.get(url_of_api1, data).json()
r2 = requests.get(url_of_api2, data).json()
r3 = requests.get(url_of_api3, data).json()
我希望r1、r2和r
浏览 2提问于2015-07-16得票数 0
回答已采纳
我正在尝试获取Windows主机上管理员的凭据。我在mingw64_shell之下。
这是我的证书：
$ klist凭据缓存:文件:/tmp/krb5cc_1049076主体: Administrator@CORP.PEROKSID.COM
颁发期限主体Jan 4 2016 10:14:07 2016 Jan 4 20:14:07 2016 krbtgt/CORP.PEROKSID.COM@CORP.PEROKSID.COM
下面是我的代码：
#include <stdio.h>
#include <string.h>
#include <gss.h>
s
浏览 0提问于2016-01-05得票数 0
异步正在引发我的spyder =>想用concurent.futures库替换它的问题
如何仅依靠concurent.futures库asyncio.get_event_loop().run_until_complete(api(message))替换以下代码
精确函数如下所示
def async_loop(api, message):
return asyncio.get_event_loop().run_until_complete(api(message))
浏览 3提问于2022-05-06得票数 0
3回答
我想让下面的代码并行化：
for(int c=0; c<n; ++c) {
Work(someArray, c);
}
我是这样做的：
#include <thread>
#include <vector>
auto iterationsPerCore = n/numCPU;
std::vector<std::future<void>> futures;
for(auto th = 0; th < numCPU; ++th) {
for(auto n = th * iterationsPerCore; n <
浏览 8提问于2012-12-12得票数 8
我用python得到了下面的json对象。我想排除以下positionAmt值大于0的对象。我该怎么做呢？ 如果positionAmt的值大于等于零，则删除它所在的行。 def webhook(request):
webhook_received_json = json.loads(request.body)
while True:
get_active_position()
def get_active_position():
print("get_active position")
sleep(3)
futu
浏览 12提问于2020-10-31得票数 0
回答已采纳
2回答
Azure AD B2C有一个OpenID连接元数据端点，它允许应用程序在运行时获取信息。这个端点有关于令牌签名键、令牌内容和端点的信息，我需要查询这个端点以获得jwk_uris。jwk_uri有用于对jwt签名的键的uri。我需要把这些钥匙缓存不超过24小时。有人能建议我在春天怎么做吗？有什么api支持这一点吗？
浏览 0提问于2016-04-28得票数 0
回答已采纳
我有多个用例，需要根据特定的用户操作触发预定义的事件。
例如，假设在应用程序中创建NewUser时，它必须异步调用CreateUserInWorkflowSystem和FireEmailToTheUser。还有许多其他这种性质的业务案例，其中事件将基于用例进行预定义。我可以使用Promises/Futures对这些事件进行建模，如下所示
if 'NewUser' then
call `CreateUserInWorkflowSystem` (which will be Future based API)
call `FireEmailToTheUser` (w
浏览 6提问于2014-06-25得票数 1
1回答
我最近更新了我安装的所有pip软件包，我不能再导入mpi4py了。如果我试图加载它，就会得到一个错误ImportError: No module named mpi4py，无论是在交互模式下还是在运行脚本时。(python2.7和python 3也会出现这种情况。)(如果是相关的话，我仍在使用。)
运行$ python -c "import mpi4py; print(mpi4py.__file__)"输出是：
Traceback (most recent call last):
File "<string>", line 1, in <mo
浏览 3提问于2017-11-23得票数 2
回答已采纳
2回答
下面的组合框设置为通过API调用放置一些记录，然后在页面上显示。当用户单击submit时，我需要提交2个值，1) gmiExchangeCode和2) gmiFuturesCode。第一个值通过此表单的字段工作，gmiFuturesCode不用于更新隐藏的表单字段。
}, {
xtype: 'combo',
autoLoad: true,
hideTrigger: true,
fieldLabel: 'Product',
displayFiel
浏览 1提问于2018-10-02得票数 0
回答已采纳
2回答
当我运行binance.py文件时，我得到一个类似以下的错误。我在课堂上发送数据。我该如何解决这个问题？ import websockets
from binance.client import Client
from binance.websockets import BinanceSocketManager
class BinanceFutures(object):
print("binance futures class")
# websocket start
futures_api_key = "oooo"
futu
浏览 10提问于2020-11-01得票数 0
回答已采纳
我在aws lambda中有下面的代码可以从API获得响应，直到状态完成为止。我使用了来自concurrent.futures的concurrent.futures。
这是示例代码。
import requests
import json
import concurrent.futures
def copy_url(headers,data):
collectionStatus = 'INITIATED'
retries = 0
print(" The data to be copied is ",data)
while (collec
浏览 2提问于2020-01-30得票数 3
我已经创建了两个版本的程序来添加数组的编号，一个版本使用并发编程，另一个是顺序编程。我的问题是，我不能让并行程序返回更快的处理时间。我目前使用的是Windows 8和Python 3.x。我的代码是：
from concurrent.futures import ProcessPoolExecutor, ThreadPoolExecutor, as_completed
import random
import time
def fun(v):
s=0
for i in range(0,len(v)):
s=s+l[i]
return s
def su
浏览 1提问于2020-07-14得票数 0
我一直在使用Python从API中获取数据，但是我希望通过使用requests_futures异步运行来加快它的速度。我每分钟只允许200个API请求，所以我必须检查这一点，并在重试之前等待指定的秒数。此数字将在Retry-After头中返回。以下是最初的工作代码：
session = requests.Session()
for id in ticketIds:
url = 'https://colorfront.zendesk.com/api/v2/tickets/' + str(id) + '/comments.json'
req
浏览 8提问于2019-10-06得票数 3
我试图使用机箱在Rust中编写一个简单的TCP客户端。我的代码非常接近减去TLS：
extern crate futures;
extern crate tokio_core;
extern crate tokio_io;
use futures::Future;
use tokio_core::net::TcpStream;
use tokio_core::reactor::Core;
use tokio_io::io;
fn main() {
let mut core = Core::new().unwrap();
let handle = core.handle();
浏览 9提问于2017-10-07得票数 11
回答已采纳
我是Rust的新手，并且使用Tonic编写了一个简单的应用程序，该应用程序将在gRPC上传输一些值。这些值最初是作为BoxStream (Pin<Box<Stream>>)从外部库中获取的，而requires的API需要一些实现Stream的东西(当然Pin不需要)。 Tonic's streaming example使用ReceiverStream将mpsc频道转换为流，并派生出一个线程将值推入其中。这将要求流的生命周期为'static，这不是我的实际实现的选项，因为我的流的生命周期与返回它的类相关联。 最好的方式是提供一些实现流的东西，我可以从我的
浏览 67提问于2021-09-10得票数 0
回答已采纳
3回答
Scala Futures和Akka Futures有什么不同，其中一个比另一个更好吗？从概念上讲，它们看起来很相似，使得非阻塞、异步编程变得很容易。
浏览 1提问于2013-09-10得票数 2
std::result::Result实现，但是下面的代码没有编译：
extern crate futures; // 0.1.25
use futures::{future::Either, prelude::*, sync::mpsc};
fn example() -> impl Future<Item = (), Error = ()> {
let (tx, rx) = mpsc::channel(0);
let data = Some(1);
match data {
Some(d) => Either::A(tx.s
浏览 0提问于2018-10-29得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
