我正在并行地执行一系列异步调用，如下所示：
txs = await asyncio.gather(*[fetch_tx_details(s["signature"]) for s in sigs])
这些调用有时会失败，因此我对每个调用都做了退避处理，如下所示：
@retry_with_backoff(10)
async def fetch_tx_details(sig):
# stuff
其中退避的定义如下：
def retry_with_backoff(retries=5, backoff_in_ms=100):
def wrapper(f):
浏览 4提问于2022-02-27得票数 0
回答已采纳
我正在处理一个需要通过API方法调用使用JavaScript的项目。我是一名Java程序员，以前从未做过web开发，所以我在这方面遇到了一些麻烦。
这个API方法是异步的，它在while循环中。如果返回空数组，则while循环结束。否则，它会循环。代码：
var done = true;
do
{
async_api_call(
"method.name",
{
// Do stuff.
},
function(result)
{
if
浏览 4提问于2017-03-28得票数 19
1回答
我的项目要求我运行一个阻塞代码(从另一个库)，同时继续我的异步时:真循环。代码如下所示：
async def main():
while True:
session_timeout = aiohttp.ClientTimeout()
async with aiohttp.ClientSession() as session:
// Do async stuffs like session.get and so on
# At a certain point
浏览 2提问于2022-03-19得票数 0
回答已采纳
2回答
我对nodejs线程有一些困惑。
据我所知，nodejs运行在一个线程中。如果调用了异步函数，nodejs将创建一个新线程来运行这些异步代码。在异步代码完成之后。event loop将获得异步结果，并在另一个新线程中触发回调函数。
为了进行测试，我进行了以下代码测试：
var fs = require("fs");
fs.readFile('package.json','utf-8', function (err, data) {
if(err)
console.log(err)
else
con
浏览 4提问于2016-05-19得票数 1
回答已采纳
我用C#编写了一个高性能的SocketAsyncEventArgs服务器。我一直在用两个非常简单的客户端测试它的性能，每个客户机都创建了2000个并行的连续循环。一个客户端使用对TcpClient的异步调用；另一个客户端使用同步调用。
异步
Parallel.For(0, numClients, parallelOptions, async i =>
{
while (true)
{
var tcpClient = new TcpClient();
try
{
await tcpClient.Con
浏览 0提问于2018-08-09得票数 3
2回答
我一直在开发一个客户机应用程序，该应用程序使用异步和等待关键字异步连接到服务器。我试图异步调用一个具有无限循环的方法，该方法每隔几秒钟检查一次internet连接。以下是启动连接时的初始代码。
private async void button1_Click(object sender, EventArgs e)
{
if (button1.Text == "Connect")
{
button1.Enabled = false;
await ConnectClient();
浏览 0提问于2014-07-29得票数 0
回答已采纳
我对python很陌生，并且很难理解为什么我的协同机制不起作用。
在当前代码中，只有一个作业正在运行，另一个作业始终处于空闲状态。为什么？
class Worker:
def job1_sync(self):
count = 0
while True:
print('JOB A:', count)
count = count + 1
def job2_sync(self):
count = 0
while True:
浏览 0提问于2018-01-27得票数 2
回答已采纳
我似乎找不到我在寻找的信息，我需要第二双眼睛。我不想做这个测试，只是一个视觉的检查和理论的讨论。
我的草稿设置了一个bool，它只允许在返回的任务将其值设置为Task.IsCompleted时运行异步方法。我的问题是，这段代码会按照我的设想来做吗?如果没有，那么一次只执行一次调用的替代方案是什么？(假设无限循环和异步任务保持不变)
您可以公平地假设RunAsync()是一个异步方法，由异步关键字表示，包含一个返回Task实例的可访问任务。
bool asyncOutputCallAllowed = true;
while (true)
{
if (asyncOu
浏览 3提问于2017-04-09得票数 1
回答已采纳
我的以下代码试图从URL打开和读取CSV文件的内容。CSV文件包含我在地图上绘制经度和经度。我已经成功地执行了代码，同时将CSV文件放入资产中。现在我只想做同样的事情，但是要在服务器上找到文件。任何帮助都将不胜感激。下面的代码片段运行，打开地图，但没有为我绘制任何点。前两行是我在将文件移动到服务器后所做的更改，其余代码是相同的：
try {
URL url = new URL(PATH);
BufferedReader reader = new BufferedReader(new InputStreamReader(url.openStre
浏览 0提问于2017-08-31得票数 0
1回答
在下面简单的asyncio Python程序中，bar_loop应该在循环之间连续运行1秒的延迟。
事情就像我们所期望的那样
async def bar_loop(self):
while True:
print('bar')
但是，当我们添加一个asyncio.sleep(1)时，循环将结束而不是循环。
async def bar_loop(self):
while True:
print('bar')
await asyncio.sleep
浏览 5提问于2021-06-10得票数 0
回答已采纳
2回答
我必须构建一个应用程序，在该应用程序中，我的计算机从不同的串口接收信息。
我的计划是每个端口使用一个线程来读取数据，使用另一个线程来解析和保存数据。线程之间的通信是通过async.queue完成的，但是我的实现有问题。
我用一个读线程做了一个简单的例子，当我尝试它时，我在实现中发现了一个问题。
import asyncio
import serial
from enum import Enum
EOL = b'\x17\x00'
class IdMessage(Enum):
ACK = 0xa0
PLS = 0xa1
async def read(port
浏览 7提问于2022-11-20得票数 0
我有一个连接到数据库并返回结果的json函数。对于数据库中有多少条评论，它会这样做大约15次。json函数位于一个while循环中，它会不断重复，直到从数据库中取出所有注释，或者直到它达到15条注释。问题是，当应用程序加载评论时，它会在应用程序的onCreate部分进行加载。我希望应用程序加载，然后在后台加载json函数。我知道我可以用异步任务做到这一点，但我不熟悉它们。所以我希望有人能告诉我如何将这段代码放入异步任务中。
UserFunctions CollectComments = new UserFunctions();
JSONObj
浏览 2提问于2013-07-03得票数 0
下面代码中的两个coroutintes运行在不同的线程中，不能通过asyncio.Queue相互通信。在producer在asyncio.Queue中插入一个新项后，consumer无法从该asyncio.Queue中获取该项，它将在方法await self.n_queue.get()中被阻塞。
我尝试在asyncio.Queue的consumer和producer中打印I，发现它们是相同的。
import asyncio
import threading
import time
class Consumer:
def __init__(self):
self.n
浏览 8提问于2022-03-03得票数 1
2回答
所以这就是我的设想。我有一个python脚本，它在一个接收用户输入的无限while循环中运行。
但是，现在我希望另一个函数每n秒钟执行一次，而主循环(它正在阻塞(等待python的But ()函数))仍在运行。我已经研究过异步和调度，但它们似乎不适用于阻塞函数调用，或者是我弄错了？
我已经研究过多重处理，但我无法思考我到底该如何去做。
编辑：
if __name__ == "__main__":
def survivor():
count = 5
while count:
print("alive"
浏览 0提问于2018-02-19得票数 0
回答已采纳
我正在尝试使用Thread来做一个Android游戏，它可以重复绘制、移动和其他循环。
在执行方法时，我遇到了问题，该方法使用"do while“循环搜索值。执行此方法时，直到此进程未结束时，线程才会继续。
避免这种情况的最佳选择是什么？在该方法中创建另一个线程？如果你能举个例子，我会非常感激的。
以下是一些伪码：
void mainLoop(){
drawElements();
moveElements();
//...
//...
reposition();
}
void reposition(){
// this stops my
浏览 2提问于2014-01-02得票数 0
回答已采纳
2回答
我试图以非阻塞的方式执行异步无限循环函数。目前，我有以下代码：
class OpcuaClient():
def __init__(self):
...
#subscribe to changes
loop = asyncio.get_event_loop()
loop.create_task(self.subscribe_to_node(self.type_Nid))
loop.create_task(self.subscribe_to_node(self.housingSerial_Nid))
浏览 9提问于2022-02-28得票数 3
回答已采纳
1回答
C#任务队列
、、、
我需要按顺序处理任务。所以这个类订阅了一些事件。在处理事件时，必须将异步方法添加到队列中，并可能在之前所有任务完成后执行。此时它是这样实现的:但是当firs事件被引发时，ProccessTasks方法停止工作。
public class class view
{
private void ModelUpdatedEventHandler(object sender, EventArgs args)
{
taskQueue.Enqueue(new Task(() => Invalidate()));
}
private void MoveC
浏览 0提问于2014-03-26得票数 0
1回答
当您使用Node.js时，您正在使用异步编程。
要处理一个层次结构，显然需要使用回调。我还知道一些函数阻塞了主事件循环，例如readFileSync()。
但是我注意到，即使像for循环这样简单的东西也会阻塞主事件循环。
示例：
function func1() {
for(var i = 0; i < 1000000000; i++) {
}
console.log("func1")
}
function func2() {
console.log('func2')
}
func1()
func2()
在本例中，'
浏览 1提问于2018-05-24得票数 1
回答已采纳
from telethon import TelegramClient, functions, sync, events
from Message import fetch_text, fetch_list
import time
from telethon.errors import *
from threading import *
import asyncio
class Shill():
def __init__(self,T_id,T_hash,owner):
self.t_id = T_id
self.t_hash = T
浏览 4提问于2022-04-21得票数 -1
1回答
我不明白在io_context停止的情况下我怎么能返回句柄。最小示例：
void my_class::async_get_one_scan(
std::function<void(const boost::system::error_code& ec,
std::shared_ptr<my_chunked_packet>)> handler)
{
asio::spawn(strand_, [this, handler] (asio::yield_context yield)
{
浏览 7提问于2018-07-25得票数 1
回答已采纳
下面的代码意味着什么吗？如果是的话，使用它的场景是什么？如果睡眠时间不同，有什么不同？
...
while True:
asyncio.get_event_loop().run_until_complete(asyncio.sleep(1))
...
浏览 4提问于2021-06-01得票数 0
回答已采纳
当await在promise上运行时，我有三个循环三次的片段。
在第一个片段中，它和我预期的一样工作，i的值随着每个await的减少而减少。
let i = 3;
(async () => {
while (i) {
await Promise.resolve();
console.log(i);
i--;
}
})();
输出：
3
2
1
在第二种情况下，i的值会不断减少，直到达到零，然后执行所有的awaits。
let i = 3;
while (i) {
(async () => {
await Promise.resolv
浏览 0提问于2019-03-24得票数 17
这是我的主要代码：
buyButton.setOnClickListener(new OnClickListener() {
@Override
public void onClick(View v) {
MyApplication myApplication = (MyApplication) getApplication();
userID = myApplication.getUserID();
// 布局文件转换为view对象
LayoutI
浏览 3提问于2014-04-11得票数 0
回答已采纳
我有两个活动Activity1和Activity2。单击按钮时，我将从Activity1切换到Activity2。但由于网速较慢，Activity2需要很长时间才能加载。在加载活动之前，将显示空屏幕。
我希望显示一个进度条，而不是黑屏，当Activity2准备好时，关闭进度条，而不是让用户感到沮丧。
我完全不知道该怎么做或者怎么开始。我是android的新手。请帮助我提出建议或分享任何关于这方面的链接！！
提前感谢！！
浏览 0提问于2013-08-09得票数 0
1回答
我只是遇到了一种奇怪的行为。我有一个MongoDB集合allCustomers，并试图填充它，只要Customers.countDocuments()返回的值低于3。模型和模式被导出并正确访问，因为它通过使用if而不是while来添加条目。不幸的是，这不是我的要求，我也不合理。
let Customer = require('./models/customer');
router.get('/', function (req, res) {
Customer.countDocuments({}, function (err, count) {
浏览 2提问于2019-10-23得票数 0
回答已采纳
主程序启动一个任务，即通道的使用者任务。使用者任务代码是：
while (await channelReader.WaitToReadAsync())
{
while(channelReader.TryRead(out item))
{
console.writeline("item is"+item.clientId);
}
}
有套接字服务器。当套接字客户端连接到服务器时，服务器将为每个客户端
浏览 2提问于2021-02-05得票数 0
回答已采纳
我有发电机
function* pendingPage() {
let value = 1;
while (true)
yield getPage(value++);
}
我有getPage()函数
async function getPage(value) {
const page = await service.getValidations(value);
(page.data.customers.length === 0) ? service.isCustomersFinished = false : console.log(page.da
浏览 1提问于2017-08-28得票数 3
回答已采纳
1回答
在类的某些方法中，我有一个永久的while循环
@gen.coroutine
def process_task_queue(self):
while True:
#print ("Hello from async while")
if not self.q:
continue
#just example
据我所知，“时间”是非阻塞相对龙卷风io_loop。
比我用tornado.testing创建unittest
class TestMSGB(AsyncTes
浏览 0提问于2015-08-17得票数 0
回答已采纳
我有一个函数，为列表中的每个对象创建一个BackgroundWorker，我现在要做的是将创建的工人数量限制在20个，当他们完成时，处理列表中的下一个项目。我正在考虑使用一个队列，在处理之前，检查队列大小(如果它是<20 )，然后创建工作人员并将其添加到队列中。我的问题是，当该项目完成后，如何将其从队列中删除？如何将循环设置为等待工作人员可用？
编辑--我认为我已经接近了--这就是我现在所拥有的，但问题是程序被while循环卡住了：
var myObjectList = new List<myObject>();
myObjectList = PopulateList();
浏览 3提问于2013-11-20得票数 3
回答已采纳
1回答
我正在为我的Min克拉夫特服务器制作一个插件，它每5秒更新一次API，其中包含大量的在线播放器。每次服务器启动时，它都会在启用插件时卡住。
这是一项功能：
public static void playerListLoop(String status, int onlinePlayers) {
Boolean on = true;
try {
while (on = true) {
try {
URL url = new URL("http://192.
浏览 2提问于2021-01-07得票数 0
我一直在为JSON解析编写代码，但在logcat中显示了以下错误
08-27 10:25:49.628: E/AndroidRuntime(816): java.lang.RuntimeException: Unable to start activity ComponentInfo{com.mokshya.hosprsing/com.mokshya.hosprsing.HomeActivity}: java.lang.RuntimeException: Your content must have a ListView whose id attribute is 'android.R
浏览 0提问于2012-08-27得票数 0
回答已采纳
我今天在为一个关于液态民主的项目而挣扎。在委托投票时，我有一个While循环来检查没有代表团被遗忘，这个算法有一个有趣的行为：
Vote.count({
propId: propId,
delegation: true
}, function(err, voteNumber) {
var maxDelegation = voteNumber;
for (var d = 1; d < maxDelegation + 1; d++) {
var delegationsLeft = 1; //Is calculated to see if someone delegat
浏览 2提问于2018-01-10得票数 0
回答已采纳
2回答
如何通过按下按钮来停止while循环。
while (thirdDigit <= 9 && stopLoop == false) {
while (sixDigits <= 999999 && stopLoop == false) {
perspective = prefix + thirdDigit.toString() + sixDigits.toString();
url = perspective + urlSuffix;
validateUrl(url, numberListTiles, perspectiv
浏览 1提问于2020-03-23得票数 1
1回答
我已经创建了一个实现异步重试模式的方法。实际上，我希望当我调用此方法时，请求应该在单独的线程中处理，并且应该延迟重试
private <R> CompletableFuture<R> withRetryRequest(Supplier<CompletableFuture<R>> supplier, int maxRetries) {
CompletableFuture<R> f = supplier.get();
for (int i = 0; i < maxRetries; i++) {
浏览 0提问于2020-05-06得票数 0
1回答
我有一个连接到IBAction的按钮，它应该在循环之前隐藏，但它永远不会隐藏。
- (IBAction)method:(id)sender
{
button.hidden = YES;
while(...) //button should be hidden while control is in loop but this never happens.
{
}
}
不知道为什么这不起作用，任何帮助都将不胜感激。
浏览 0提问于2013-03-18得票数 0
回答已采纳
1回答
我有一个大型python应用程序(现在转换为python3)，主代码在无限循环中运行。
while (True):
#Do loads of stuff, connect to rs485 devices, obtain their status etc.
我想在这个应用程序中使用websockets。我现在已经把它转换了，所以结构是：
def mainPoll():
#Do loads of stuff (omitted for brevity)
while (True):
mainPoll()
作为起点的websockets示例代码(来自)是：
import
浏览 4提问于2020-04-27得票数 1
回答已采纳
1回答
我将公共API中的一些数据添加到views.py中的sqlite数据库中。并使用django rest框架将其传输到axios (vuejs应用程序显示此数据)。公共应用程序接口每秒更新一次，我希望每次都运行我的views.py代码，以便自动更新我的数据库。
我试着写了一些粗略的代码，比如：
While True:
#my views.py function
time.sleep(30).
axios可以有一个函数来启动views.py代码，或者一些内部的django函数来运行我的代码吗？
浏览 9提问于2019-08-01得票数 0
我的类有一种方法可以执行如下操作：
async foo(..., callback){
do{
for(...){
await bar1();
await bar2();
}
}
while(...);
callback();
}
我希望能够在命令下中断循环，所以这就是我的方法：
async foo(..., callback){
this.stop = false; // Reset the property
do{
for(...){
浏览 4提问于2017-11-20得票数 1
回答已采纳
因此，我使用在我的应用程序中嵌入了一个条形码扫描仪。问题是它需要一段时间才能启动，2到4秒。在此期间，UI挂起，我将其添加到AsyncTask中，UI不再挂起，但我添加到AsychTask中的进度对话框不显示。当我向doInBackground添加thread.sleep时，对话框确实会显示，但在thread.sleep结束时再次挂起。有谁知道如何让用户知道扫描仪正在加载？
class loadScanner extends AsyncTask<Void, Void, Void> {
@Override
protected void onPreExecute(){
浏览 0提问于2015-04-02得票数 1
我正在阅读node.js中的事件循环。根据我在stackexchange中阅读的各种文章和文章，我得到所有回调都附加在任务队列的末尾，并且在主文件执行之后，队列中的所有任务都按顺序执行。我试着用一个小程序来确认。在那里我发现了一种奇怪的行为。下面是我创建的main.js文件的内容。
//Declare file open event handler
var fs = require("fs");
var ws = fs.createWriteStream("C:\\test.txt");
ws.on("open", function(fd) {
浏览 4提问于2015-04-30得票数 4
回答已采纳
1回答
我正在创建一个自定义的TCP/IP客户机/服务器应用程序，在试图停止服务器时遇到了麻烦。最初，我的代码使用一个TcpListener在指定的端口上侦听，我的(为方便而简化的)代码启动和停止服务器如下：
private bool state;
private TcpListener listener;
private CancellationTokenSource tokenSource;
private Dictionary<string, ConnectedClient> clients;
private List<Task>
浏览 1提问于2017-05-12得票数 0
回答已采纳
我的应用程序中有多个异步任务，我希望在满足特定条件时执行它。例如,
类Task1扩展了AsyncTask...
类Task2扩展了AsyncTask..
类Task3扩展了AsyncTask...
我有一个while循环，用于迭代map中的一些值。例如：
while(iterator.next())
{
Map.Entry pair = (Map.Entry) it.next();
String title = pair.getKey().toString();
if(title.equals("one"))
{
//execute tas
浏览 2提问于2015-07-27得票数 0
假设我在Node.js应用程序中有以下代码：
function bar(){
//do_stuff
return value;
}
app.get('/',function(req,res){
var result = bar();
res.send(result);
});
假设在函数中，//do_是一个多达1000万的while循环。它是否保证函数将完成，返回它的值，该值将被分配给结果，只有这样才会执行？
如果在函数中，//do_涉及数据库查询(返回值取决于这些查询)，该怎么办？在这种情况下，我是否可以确保res.send(resu
浏览 0提问于2016-10-10得票数 0
回答已采纳
我在制造一个不和谐的机器人。
我的不和谐的机器人所做的是监听整个服务器的消息并实时打印出来。
但是，我也希望代码能够不断地从控制台接收输入，并在特定的服务器ID中打印出来。
@bot.event
async def on_message(message):
# Prints message
@bot.event
async def on_ready():
# Execute on-ready stuff
while True:
kb = input(">>>")
#Delivers the mess
浏览 1提问于2020-06-18得票数 2
回答已采纳
因此，我从线程中动态地生成列表视图，这样它就可以异步工作。我刚刚实现了googles SwipeRefreshLayout。因此，在onRefresh调用中，我想重新构建列表。然而，我尝试的每一件事要么什么也不做，要么就是告诉我。
“只有创建视图层次结构的原始线程才能触摸其视图。”
列表是如何构建的
public void updateQueue(final ListView lstvw, Context ctx, final Boolean refresh) {
final String [] stringArray = stringArrayList.toArray(n
浏览 0提问于2014-07-22得票数 0
回答已采纳
我试图在我的onCreate方法中创建一个while循环，但它总是崩溃(如果没有这个循环，效果会很好)。有人能帮帮我吗？
代码如下：
while(runnersNearby.size()<3)
{
GeoQuery geoQuery = geoFire.queryAtLocation(new GeoLocation(lat, lang), radius);
geoQuery.addGeoQueryEventListener(new GeoQueryEventListener() {
@
浏览 1提问于2016-08-23得票数 0
回答已采纳
2回答
我希望异步读取流(串行、tcp等)中的数据，并触发事件通知其他组件。
下面是伪代码，假设" stream“是一个有效的流。
public class Reader {
private _stream;
private _buffer = new bytes[4096];
public event Action<byte[], int> DataRecieved;
public async void StartReading() {
while (true) {
var nbytes = await
浏览 4提问于2015-07-07得票数 3
回答已采纳
我在循环中使用mongodb find查询，因为我需要运行5次find查询。为此，我使用了以下代码： let result = {};
let miles = ['5','10','15','25'];
let i = 0;
while (i < miles.length) {
Shops.find({ 'shopInfo.address':{ $geoWithin:{ $centerSphere: [ [ 75.83183541365247, 30.902146005639267 ], miles[
浏览 22提问于2019-04-26得票数 1
1回答
我正在使用Flask开发一个基于区块链的应用程序，我需要一个端点函数，当调用该函数时，所有运行的函数都应该中止。例如： import sys
import flask
import time
app = flask.Flask(__name__)
@app.route("/infi1")
def infi1():
while True:
print("infi1")
time.sleep(1)
@app.route("/infi2")
def infi2():
while True:
浏览 62提问于2020-06-14得票数 1
回答已采纳
1回答
目标是不断地从另一个tcp服务器接收一些消息。与内置tcp套接字的python不同，我切换到QTcpsocket。服务器端确认客户端连接。那么，readyRead似乎从来没有被释放，并且不知道是什么问题。
我已经尝试过python内置的套接字，它工作得很好。
import socket
import sys
import struct
import json
import os
#crate a TCP/IP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
#Connect the socket to the
浏览 0提问于2019-05-31得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
