基于产量的协程是真正的协同程序吗？
基于产量的协程是真正的协同程序吗？
这个问题涉及到协程和协同程序的概念。我们先来了解一下这两个概念：
- 协程（Coroutine）：协程是一种轻量级的线程，它的调度和管理由程序员自行控制。协程可以在一个线程内实现多任务的并发执行，从而提高程序的并发性能。协程的执行和切换不会像线程那样消耗太多资源，因此它们在某些场景下比线程更加高效。
- 协同程序（Coroutine-based Programming）：协同程序是一种基于协程的并发编程模型。在这种模型中，程序员可以通过编写协程函数来实现任务的并发执行。协同程序的核心思想是将程序的执行过程分解为多个协程，这些协程可以在一个线程内并发执行，从而提高程序的并发性能。
现在我们来回答这个问题：基于产量的协程是真正的协同程序吗？
基于产量的协程和协同程序都是基于协程的并发编程模型，它们的目的都是为了提高程序的并发性能。因此，基于产量的协程可以被视为一种协同程序。
产量（Throughput）是指在单位时间内完成的任务数量，而协程的调度和管理是由程序员自行控制的。因此，基于产量的协程可以通过合理地安排协程的执行顺序和时机来提高程序的并发性能，从而实现高产量的任务处理。
总之，基于产量的协程是一种协同程序，它可以通过合理地安排协程的执行顺序和时机来提高程序的并发性能。
相关·内容
问题是我的Lua服务器无法同时接受多个请求。我试图让每个客户端消息在其上协同程序中处理，但似乎失败了。
while true do
local client = server:accept()
coroutine.resume(coroutine.create( function()
GiveMessage( client )
end ) )
end
这段代码实际上似乎不能同时接受多个客户端消息。这种方法有什么问题？谢谢你的帮助。
浏览 2提问于2011-02-19得票数 1
回答已采纳
2回答
我已经看到很多关于python中的协程的演讲和文章。它们被认为是“微线程”，我听说它们可以提高性能。
协程如何提高性能？到目前为止，我看到的是它们是单线程的，并且是按顺序执行的。我同意从设计的角度来看，它们非常优雅，特别是在生产者/消费者类型的应用程序中。
我想我没有抓住要点。有人能帮我解释一下吗？
浏览 0提问于2011-07-05得票数 16
回答已采纳
与FlowCollector中的emit()函数不同，yield函数在取消协同例程时不协同工作。以下是示例程序：
import kotlinx.coroutines.flow.collect
import kotlinx.coroutines.flow.flow
import kotlinx.coroutines.runBlocking
import kotlinx.coroutines.withTimeoutOrNull
fun main(): Unit = runBlocking {
withTimeoutOrNull(5000) {
getFlow().coll
浏览 2提问于2021-06-10得票数 0
我想知道既然withContext和suspendCoroutine都是挂起函数，除了suspendCoroutine提供延续的事实之外，它们之间还有什么不同，所以如果我们使用suspendCancellableCoroutine变体，你可以控制它何时恢复或取消。我想说两者都可以用来停止回调(这是协程的一个优点)。有什么主要区别吗？
浏览 52提问于2020-07-25得票数 2
回答已采纳
我对语言设计有点偏执，目前我正在尝试我自己的爱好语言。()
真正让我头疼的一件事是“生成器”和"yield“关键字。我知道C#使用AST转换将枚举器方法转换为状态机。
但是它在其他语言中是如何工作的？有没有办法在没有AST转换的语言中获得生成器支持？例如，像Python或Ruby这样的语言会求助于AST转换来解决这个问题吗？
(问题是生成器是如何在不同的语言中实现的，而不是如何用其中一种语言编写生成器)
浏览 1提问于2010-04-15得票数 3
回答已采纳
2回答
带延迟的Kotlin协程单元测试
、、、、
我正在尝试对一个使用delay()的Kotlin协程进行单元测试。对于单元测试，我并不关心delay()，它只会减慢测试速度。我希望以某种方式运行测试，使其在调用delay()时不会真正延迟。
我尝试使用委托给CommonPool的自定义上下文运行协程：
class TestUiContext : CoroutineDispatcher(), Delay {
suspend override fun delay(time: Long, unit: TimeUnit) {
// I'd like it to call this
}
overrid
浏览 106提问于2017-11-08得票数 36
回答已采纳
所以我和一位同事聊了聊，发现了，它描述了一个使用Fiber在C#中实现协程的方法。
本文中的Yield实现是针对.NET 1.1的，因此它早于.NET 2.0中出现的yield return语法。
乍一看，这里的实现可能更快，并且可以很好地扩展到多个CPU。
有人用过吗？
浏览 0提问于2009-12-10得票数 8
回答已采纳
当您开始学习Kotlin协程时，您看到的第一个示例之一是可以启动数十万个协程，但在尝试对线程执行相同的操作时会遇到OutOfMemory异常。
虽然这个例子很“酷”，但我不认为它对现实世界的Android应用程序开发有什么用处，甚至有点误导。当然，您可以启动数十万个只做delay()的协程，但在现实中，您要么启动执行某种IO或某种计算的协程。
例如，如果您启动了数十万个协程，并且每个协程都使用Retrofit执行一个网络请求，那么它不会比传统地使用没有协程的Retrofit更轻量级，因为okhttp仍然会为每个请求阻塞一个线程。
当您使用协程进行计算时，情况也是如此。那么它也不是更轻量级的，因
浏览 1提问于2020-05-07得票数 3
不久前，我从David Beazley的协程程序上读到了，我想知道是否有实际的基于Python的软件使用它们？
为什么协程看起来像是Python中最未使用的功能？
浏览 0提问于2011-04-23得票数 8
的CoroutineScope是什么
runBlocking {
// some code here
}
在Kotlin Coroutines？
当类被垃圾回收时，它是被调用的类的本地，并且协程被垃圾回收吗?如果它还在运行，它会导致内存泄漏吗？
浏览 4提问于2021-09-20得票数 1
1回答
C#异步，无任务等待
、、、
通过创建一个或多个等待程序和等待对象，是否可以在C#中构建协程？
理想情况下，我希望能够写出如下内容：
void async Click() {
var mouse_position = await left_mouse_click();
await shoot_projectile();
}
然后从Click方法中获得一些东西，我可以在另一个异步方法中等待，或者可以使用某个MoveNext/GetResult方法显式迭代。
最终目标是我需要为游戏开发框架()集成C# async/await和F#单行协程。
浏览 1提问于2013-03-17得票数 11
回答已采纳
2回答
Jetbrains在每一篇关于kotlin的文章中都谈到了异步编程。但我不明白为什么它们被称为异步？据我所知，kotlin协程--这是一个带有预初始化线程池的状态机。我们有一个工作线程池和一个io线程池。对我来说，这只是一个多线程编程。如果我们向协程发送阻塞代码，线程将被阻塞。如果我们使用async方法(来自默认协程库)，它会给我们一种异步工作的错觉，但这只是将“job”发送到另一个线程。
如果我们使用带有协程的async io，另一个问题。但这是IO API异步，而不是kotlin协程。与其他语言相比，Java没有很好的io异步api (可能是错误的)。据我所知，.NET已经重建了他们的异步
浏览 5提问于2021-09-17得票数 3
我想在actionscript中使用协程来实现状态机。
我希望能够做一些类似以下的事情
function stateMachine():void
{
sendBytes(0xFFFF);
var receiveBytes:ByteArray = yield()
sendBytes(receiveBytes);
}
stateMachine.send( Socket.read() )
就像在这个中
浏览 0提问于2009-12-17得票数 2
回答已采纳
在下面的代码中，我正在获取一些数据。如果抛出了错误/异常，我希望异常处理程序能够捕获它。完成获取后，我将使用LiveData将结果发布给正在观察的人。 我试图实现的是，一旦我发布了结果，异常处理程序就会完成它的工作。这意味着，如果处理结果的观察者也抛出了异常，我不希望协程异常处理程序捕捉到它(下面的代码中就是这种情况)。 fun loadPrerequisites(resultObserver: MutableLiveData<PrerequisiteDataHolder?>) {
val exceptionHandler = CoroutineExceptionHan
浏览 16提问于2020-03-24得票数 0
回答已采纳
典型的协程对象如下所示：
struct Coroutine
{
struct promise_type
{
int value;
Coroutine get_return_object() {return this; }
std::suspend_never initial_suspend() { return {}; }
std::suspend_never final_suspend() noexcept { return {}; }
void return_value(int v) {
浏览 0提问于2021-06-29得票数 0
1回答
大多数Boost:graph库的示例都是通过调用boost的深度优先搜索工具来执行深度优先搜索的。在创建顶点和边之后，在图上调用DFS将以深度优先的方式遍历整个图，如果我们有一个与之关联的访问者方法，它将为遍历的每个节点调用访问者方法来执行操作。
我正在寻找的是一种在图上维护迭代器的方法，当客户端调用' next ()‘时，迭代器将移动到DFS遍历的下一个顶点，再次调用next时，迭代器将移动到DFS指示的下一个顶点，而不是一次性遍历图形。
是否有使用boost:graph执行上述操作的示例？
谢谢
浏览 1提问于2012-08-18得票数 6
我的代码就在这里：
using UnityEngine;
using Assets.Helpers; //DONT COPY
using System;
using System.Collections;
public class TileManager : MonoBehaviour {
[SerializeField]
private Settings _settings;
[SerializeField]
private Transform target;
[SerializeField]
private Texture2D texture;
private GameObject
浏览 1提问于2017-03-12得票数 0
我是第一次接触龙卷风，对龙卷风的协程有一些问题。如果我有一个调用堆栈，看起来像这样：
func_a => func_b => func_c => func_d
func_d是一个异步函数，我使用了yield和@gen.coroutine装饰器。
就像这样：
@gen.coroutine
def redis_data(self, id):
ret = yield asyn_function()
raise gen.Return(ret)
我必须将yield和@gen.coroutine与func_c、func_b和func_a一起使用吗
浏览 2提问于2015-03-03得票数 1
我正在使用CoroutineWorker从房间数据库中获取一些数据，并将其发送到服务器，然后再次从数据库中删除该特定答案。我使用的是存储库模式。
class SendLocalAnswerToServer(ctx: Context, val params: WorkerParameters) :
CoroutineWorker(ctx, params) {
var useCaseHandler: UseCaseHandler? = null
var deleteAnswerFromTable: DeleteAnswerFromTable? = null
private var upl
浏览 63提问于2019-05-22得票数 0
回答已采纳
示例： import pytest
@pytest.fixture
async def phrase():
return 'hello world'
@pytest.fixture
async def replaced(phrase):
return phrase.replace('hello', 'goodbye') 方法.replace是黄色的，并且警告是： Unresolved attribute reference 'replace' for class 'Coroutine' 然
浏览 23提问于2019-04-17得票数 4
回答已采纳
我试着使用两个我想要在同一时间连续执行的例程，但只有第一个例程在运行…
我哪里错了？
async def screen(self): #first routine
Writer.set_textpos(ssd, 0, 0) # In case previous tests have altered it
wri = Writer(ssd, small, verbose=False)
wri.set_clip(False, False, False)
...
refresh(ssd)
utime.sleep_ms(200)
浏览 2提问于2020-08-08得票数 0
我对Coroutine的确切功能略知一二，所以我决定用它创建一个项目。最好的学习方式，不是吗？不管怎样，我在每个关卡的开头都有UI的工作脚本，它会告诉你什么关卡和/或它是否是一个新的检查点(产卵区域)。它还会告诉玩家还剩下多少生命和生命。我现在的问题是WaitForSeconds()没有暂停“检查点”文本，所以它直接进入图形用户界面函数，似乎跳过了检查点(Cpoint())函数。然而，通过调试日志，我知道它实际上不是这样的。这种变化在启动时发生得如此之快，以至于在读取之前就消失了。
我把协程注释掉了，因为它不间断地运行。我只想让这个代码在对撞机被联系的时候起作用。
欢迎所有的解释！我是来学习的
浏览 15提问于2018-08-25得票数 0
回答已采纳
我对Kotlin协程和线程的理解是这样的： 一个线程一次只能运行一个协程。一个线程可以同时处理多个协程。它可以挂起一个协程并运行一个不同的协程。但是在给定的时间点上，一个线程上只有一个协程在运行。您不能在同一时间点在同一线程上运行多个协程。 是这样的吗？
浏览 81提问于2020-10-05得票数 1
回答已采纳
1回答
假设我有一个包含10个线程的线程池。假设池中的一个线程执行某个任务。我希望在某些情况下，任务将停止执行，线程将执行另一个任务，只有稍后它才会返回到前一个任务，并从停止的地方继续执行。
这个是可能的吗？我该怎么做呢？
浏览 4提问于2021-10-08得票数 0
1回答
我需要保护一段代码不会在协程中并发执行。在多线程环境中防止并发执行很简单，只需使用类模板即可。但是，我的协程是从单个线程调用的，因此该解决方案不适用。
下面是我想要实现的(伪)代码：
future<http_response> send_req_async(http_request req) {
while (true) {
// Attempt to send an HTTP request
auto const& access_token{ token_store::access_token() };
auto c
浏览 15提问于2018-05-29得票数 2
回答已采纳
这是我的代码，我已经尝试了所有的协程选项，我在两个函数的开头都有语句，它会打印，但它不会在循环中做任何事情
coroutine.wrap(constantWork)()
coroutine.wrap(lookForKeys)()
循环开始于第170行之后
浏览 1提问于2020-11-29得票数 1
1回答
对异步函数的直觉
、、、
提前谢谢你，
假设你有一个异步函数：
async def create_list(num):
print("Creating a list that is length {}".format(num))
i = 0
list = []
While True:
i += 1
if i > 100000:
await asyncio.sleep(0.0001)
list.append(i)
if i == num:
浏览 4提问于2018-07-18得票数 0
我经常创建具有包含协程的函数的类。并不总是清楚该函数是否由绑定到UI的某个组件使用，或者它是否正在进行更多面向IO的后台工作。下面是一个例子：
fun myFunction() {
GlobalScope.launch {
// Do something
}
}
在本例中，未指定Dispatcher.MAIN或Dispatchers.IO。这是正确的方法吗？协程是否使用调用客户端恰好正在使用的作用域？当我明确知道我需要一个特定的作用域时，我应该只指定一个调度程序吗？
浏览 3提问于2020-01-13得票数 2
1回答
等待协同程序与等待任务的区别
、、、、
在FastAPI上，我有一个端点，它调用下面的get_1或get_2协程函数。
get_1使用await redis.get(key)
get_2使用await asyncio.ensure_future(redis.get(key))
这两个函数在功能和性能上有什么区别吗？
#redis.py
import asyncio
import aioredis
async def get_1(key):
redis = aioredis.from_url("redis://localhost")
value = await redis.get(key)
ret
浏览 2提问于2021-11-13得票数 1
我把我的思想围绕着异步，我想写一个简单的基于套接字的聊天服务器。我一直在环顾四周，想知道处理这项任务的最佳方法是什么。
不幸的是，似乎没有“显而易见的方法”。例如，我发现自己无法决定是使用@asincio.coroutine还是async def，是使用.start_server的asyncio.Protocol还是.asynchat。还是别的什么？
这在实践中真的有什么不同吗？
你能帮我照亮这个吗？
浏览 40提问于2018-07-27得票数 0
回答已采纳
2回答
我有一个关于协程实现的问题。我首先在Lua和stackless-python上看到了coroutine。我可以理解它的概念，以及如何使用yield关键字，但我不知道它是如何实现的。
我能得到一些关于它们的解释吗？
浏览 2提问于2010-08-09得票数 4
回答已采纳
1回答
我可以连接A和B的两个协程，A激发B，B激发A吗？例如，A将接受一个数字，将其打印出来，然后使用(number+1)调用B。B将打印它并使用(number+1)调用A。我希望是1,2,3,4,5，...已打印
不幸的是，这段代码确实可以正常工作。
def coroutine(func):
def start(*args,**kwargs):
cr = func(*args,**kwargs)
cr.next()
return cr
return start
_target_from_a = None
_target_from_b
浏览 1提问于2013-05-24得票数 2
回答已采纳
我在使用套接字时收到此警告。我从IO作用域协程调用startConnection方法，如果startConnection方法是挂起的，我会收到警告。我将其设为suspend，因为稍后我将从它调用一些其他的suspend方法。有什么办法可以解决这个问题吗?或者我是否应该禁止显示警告？ private suspend fun startConnection(ip: String, port: Int) {
try {
socket = Socket(ip, port)
.
.
浏览 81提问于2020-09-17得票数 0
在Python中-使用纯a = yield协程语法，而不是像asyncio这样的库-在收到响应之前发出一个HTTP请求并做一些其他事情，这是可能的吗？类似于： >>>requests.get('http://www.json-generator.com')
# do something else here while the above request is being made 就像使用AJAX一样，人们可以发出请求，而不必等待响应？或者我可能误解了协程背后的想法？
浏览 27提问于2019-01-07得票数 4
回答已采纳
1回答
我期望的结果是(0，1)或(0，1，2)，但打印的数字不断增加。我在学习关于协程的知识。我遵循了这个例子，但我对它很好奇，所以我写了代码，发现了一些奇怪的东西。 class test {
@Test
fun test() = runBlocking {
val startTime = System.currentTimeMillis()
val job = launch {
var nextTime = startTime
var i = 0
while (isActiv
浏览 21提问于2021-07-25得票数 0
我理解协程的原理。我知道如何让标准的StartCoroutine / yield return模式在Unity的C#中工作，例如，通过StartCoroutine调用一个返回IEnumerator的方法，在这个方法中做一些事情，做yield return new WaitForSeconds(1);等待一秒钟，然后做其他事情。
我的问题是:幕后到底发生了什么？StartCoroutine到底是做什么的？WaitForSeconds返回的IEnumerator是什么？StartCoroutine如何将控制权返回给被调用方法的“其他部分”？所有这一切如何与Unity的并发模型(其中许多事情在同一时
浏览 57提问于2012-10-17得票数 146
回答已采纳
3回答
使用我所见过的asyncio库，
@asyncio.coroutine
def function():
...
和
async def function():
...
可互换使用。
两者之间有什么功能上的区别吗？
浏览 2提问于2016-11-13得票数 48
回答已采纳
3回答
我刚刚开始学习Unity脚本，我很难理解为什么有些人更喜欢协程而不是状态机。
我确实理解代码对于一些程序员来说可能更具可读性，但我不能理解为什么有些人说使用协程更有利于性能。
我在Unity中使用C#，根据我对的理解。
所以也许我漏掉了什么。对于运行时性能，使用协程而不是FSM循环来处理行为和状态是否更好？若有，原因为何？
浏览 4提问于2013-02-01得票数 3
2回答
协程是如何被挂起的？
、、、、
来自kotlin文档
A coroutine is an instance of suspendable computation.
It may suspend its execution in one thread and resume in another one.
delay is a special suspending function.
It suspends the coroutine for a specific time.
Suspending a coroutine does not block the underlying thread, but allows ot
浏览 21提问于2021-11-06得票数 1
1回答
所以我有一个基本的不一致机器人，它接受输入
import discord
import asyncio
import threading
loop = asyncio.new_event_loop()
bot = discord.Client()
def run_asyncio_loop(loop):
asyncio.set_event_loop(loop)
loop.run_forever()
Hangman.set_bot(bot)
@bot.event
async def on_message(message):
bot.loop.create_task
浏览 24提问于2017-08-09得票数 0
回答已采纳
3回答
我一直在通过 codelab来了解协程。我仍然不清楚的一件事是，为什么我们需要更改调度程序来确保我们不会阻塞主/UI线程？如果协程是轻量级线程，那么当我已经在主线程上时，为什么不能在协程中调用线程阻塞函数(无论它们是否挂起)？
codelab解释说(总而言之)如果我写这段代码：
// Repository.kt
suspend fun repoRefreshTitle() {
delay(500)
}
//ViewModel.kt
fun vmRefreshTitle() {
viewModelScope.launch {
_spinner.value = tru
浏览 2提问于2020-05-24得票数 2
试图弄清楚协程是不是正确的方法。
我有三个不同的类来执行操作；我希望这三个类以任何顺序执行它们的工作，一旦这三个类都完成了，我就可以进入下一个循环，再次调用这三个类中的方法来重新开始。
和现在一样，我在每个类中都有一个方法来完成工作；在主类中，我创建了一个协程，这是我的过程的主循环。协程有一个条件，即3个类中的所有3个方法都必须完成，在一个while循环中产生返回void。这是协程的简化版本：
IEnumerator void loopFunction()
{
while (!classA.method() && !classB.method() &&
浏览 0提问于2016-02-21得票数 1
我正在编码我的游戏老板的行为，在战斗的最后阶段，老板应该冲向玩家，然后回到原来的位置。等待5秒钟，然后执行相同的操作。 我尝试使用协程和Vector2.MoveTowards()来实现这一点，但没有得到预期的效果，首先，老板不会“向”球员“移动”，而是立即出现在targetPosition中，然后只是停留在那里，不会移动。 下面是我的代码： private Vector2 chargeTarget;
private Vector2 tankStartPosition;
void Start()
{
chargeTarget = new Vector2(-5.0f, transfor
浏览 21提问于2019-05-24得票数 2
回答已采纳
1回答
我正在尝试集成一个使用asio和android上的协程的boost项目。我使用 在CMakeLists.txt文件(使用c++17)上。当我设置这个标志时，ANDROID宏变得未定义。如果我添加了-DANDROID，那么协程就会被禁用。这两个标志是不兼容的吗？我可以在Android上使用NDK的c++协程吗？
浏览 15提问于2021-03-02得票数 0
回答已采纳
1回答
纤程/协程vs定界延拓
、、、
所以我在这里读到了一篇关于并发工作窃取数据的论文：。他们提到了“子窃取vs延续窃取”，他们说，子窃取可能需要无限的堆栈空间来容纳尚未执行的任务，而不像延续窃取，这是P=#processors的一个恒定因素。
我有一个关于纤维/协程和定界延拓之间的区别的理论问题。首先，我承认协程和纤程几乎是等价的，但是纤程也等同于延续吗？我暗自怀疑我将要实现的东西是根本错误的(即。用纤程替换线程，而不是真正实现一个不需要无限内存的版本)。
浏览 7提问于2018-06-26得票数 1
在协程中执行IO绑定函数(例如，从后端请求数据)可以让我暂停执行，直到请求的结果可用，对吧？然而，一个受CPU限制的函数(例如，解析一个巨大的文本文件)并不“等待”任何东西，它只是做了大量的工作。那么，在协程中执行它不是给了我暂停执行它的好处吗？当涉及到CPU绑定函数时，协程给我的唯一(有价值的)优势是能够选择在执行函数时将被阻塞的线程(或线程池)，我说的对吗？
浏览 2提问于2019-05-07得票数 2
2回答
我已经尝试阅读了Kotlin协程的各种教程和页面，尽管它对我来说是有意义的，但我仍然没有感觉到它被点击了，我还没有准备好用协程编写异步非阻塞代码。我认为我缺少的是一张图表或图片，说明当一段协程代码执行时到底发生了什么，以及以什么顺序执行。这些代码是如何在线程级别运行的？
launch {
delay(1000)
println("World (${currentThread().name})")
}
println("Hello (${currentThread().name})")
sleep(1
浏览 1提问于2019-07-29得票数 8
下面是两个代码片段，它们几乎是相同的，除了一个在挂起协程中有线程，另一个没有。
第一个代码是：
suspend fun main(args: Array<String>) {
log(0)
coroutineScope {
log(1)
val result = suspendCoroutine<String> { continuation ->
log(2)
Thread {
log(3)
contin
浏览 6提问于2020-03-21得票数 1
据我所知，协程是一个函数调用序列，不同之处在于函数调用不会在每次调用时都分配堆栈(它们在停止时恢复)，或者我们可以说这些函数是在共享堆栈中执行的。
因此，协程的主要优势是执行速度。它不只是来自C++的内联函数吗？(如果不是调用，而是在编译期间插入函数体)。
浏览 1提问于2012-03-31得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
