从纤程内部返回一个值
是指在纤程（Fiber）中执行某个任务或函数，并将结果返回给调用者。纤程是一种轻量级的线程，可以在单个线程内实现并发执行，它提供了一种协作式的多任务处理方式。
在纤程内部返回一个值的过程通常包括以下几个步骤：
- 创建纤程：首先，需要创建一个纤程对象，可以使用编程语言或框架提供的相关API来创建纤程。
- 执行任务：将需要执行的任务或函数绑定到纤程对象上，并启动纤程的执行。
- 等待结果：在纤程执行的过程中，调用者可以通过等待纤程的完成来获取结果。这可以通过调用纤程对象的等待方法或使用相关的同步机制来实现。
- 返回结果：当纤程执行完成后，可以将结果返回给调用者。通常，纤程对象会提供获取执行结果的方法或属性。
纤程的优势在于它可以实现更细粒度的并发控制，避免了线程切换的开销，并且可以更好地利用多核处理器的性能。纤程适用于一些需要高并发、高性能的场景，例如网络服务器、游戏引擎等。
腾讯云提供了一些与纤程相关的产品和服务，例如云函数（Serverless Cloud Function）和容器服务（Tencent Kubernetes Engine，TKE）。云函数是一种无服务器计算服务，可以在云端运行用户编写的代码，支持事件触发和定时触发等方式，可以用于实现纤程的执行。容器服务则提供了一种轻量级的容器化部署方式，可以更高效地管理和调度纤程。
更多关于腾讯云产品的详细介绍和使用方法，可以参考腾讯云官方网站：https://cloud.tencent.com/
相关·内容
2回答
我有一个关于Nodejs Fibers的问题(这对我来说绝对是新的)……我有这个关于Nodejs光纤的教程，，这里有一个例子，上面写着
var fiber = Fiber.current;
db.connect(function(err, conn) {
if (err) return fiber.throwInto(err);
fiber.run(conn);
});
// Next line will yield until fiber.throwInto
// or fiber.run are called
var c =
浏览 2提问于2013-02-13得票数 3
回答已采纳
我尝试了官方网站- 中提供的以下代码。但并不像预期的那样工作。
输出：
*在调用test之前
调用test后
216.58.196.142反向："syd15s04-in-f14.1e100.net"*
预期输出：*在调用test之前
反向为216.58.196.142："syd15s04-in-f14.1e100.net“
调用test*之后
我能做些什么来让它工作呢？
var dns = require("dns"), wait=require('wait.for');
function test(){
var addresse
浏览 0提问于2017-11-09得票数 1
我对Ruby如何处理枚举数的创建感到有点困惑。基于块的迭代是有意义的，并且对我来说是有效的；我仍然不明白枚举器的返回应该如何在代码方面起作用。
下面是我正在使用的代码：
VALUE rb_RPRuby_Sender_Kernel_each_backtrace_frame( int argc,
VALUE* args,
VALUE rb_self ) {
浏览 1提问于2010-07-07得票数 0
回答已采纳
1回答
我们正在做IO操作，我们希望在一个单独的线程中运行，并且主线程不应该等待这个操作。 def seperateThread(action: F[Unit]): F[Unit]
ConcurrentEffect[F].start(action).void 如果我像下面这样调用这个函数 for {
_ <- service.seperateThread(request, languageId, cacheItinerary, slices, pricing)
} yield {} 它会在不同的纤程中执行seperateThread操作并立即返回FUnit，还是等待操作完成？
浏览 20提问于2021-07-12得票数 1
1回答
我想要的是获得光纤在上下文切换上的高效率，并在I/O期间产生CPU时间，但当工作负载足以支持更多CPU时，我希望从并行处理的事实中获得性能。
我读了一篇关于线程和光纤的很棒的文章
并阅读这个关于纤维和线程之间的比较的问题。
但我想了解一种将它们混合在一起的好方法。当然，代码示例也是受欢迎的。
浏览 3提问于2016-07-06得票数 0
2回答
为什么我们需要纤维
、、、、
对于Fibers，我们有一个经典的例子: Fibonacci数的生成
fib = Fiber.new do
x, y = 0, 1
loop do
Fiber.yield y
x,y = y,x+y
end
end
为什么我们这里需要Fiber？我可以用同样的过程重写(实际上是闭包)
def clsr
x, y = 0, 1
Proc.new do
x, y = y, x + y
x
end
end
所以
10.times { puts fib.resume }
和
prc = clsr
10.times { puts
浏览 1提问于2012-01-29得票数 102
回答已采纳
据我所知，当运行的纤程在blocked.But中时，线程可以运行另一个纤程，但事实并非如此。我创建了100个纤程，它将搜索solr.The结果，我发现所有的纤程都是在order.Another中执行的，只有当前一个纤程完成时，纤程才能执行，就像thread.This是我的代码一样。
import co.paralleluniverse.fibers.Fiber;
import co.paralleluniverse.fibers.FiberForkJoinScheduler;
import co.paralleluniverse.fibers.FiberScheduler;
import co
浏览 6提问于2016-07-27得票数 0
1回答
示例代码来自
def http_get(url)
f = Fiber.current
http = EventMachine::HttpRequest.new(url).get
# resume fiber once http call is done
http.callback { f.resume(http) }
http.errback { f.resume(http) }
return Fiber.yield
end
EventMachine.run do
Fiber.new{
page = http_get('http://www.
浏览 0提问于2012-09-30得票数 4
回答已采纳
1回答
您好，我正在尝试使用纤程等待请求，但它给出一个错误
‘错误:没有纤程无法等待’
我应该怎么做才能使用that.By，就像我不使用meteor只使用纯nodejs一样。
const Fiber = require('fibers')
const Future = require('fibers/future')
const request = require('request')
const v3_key = "*****";
// Application Declartion
function Movie() {
thi
浏览 0提问于2017-07-16得票数 1
9回答
线程和纤程有什么不同？我听说过ruby中的纤程，听说它们在其他语言中也可用，有人能简单地给我解释一下线程和纤程的区别吗？
浏览 8提问于2009-04-28得票数 212
回答已采纳
我正在尝试在Meteor中使用，以便与Twitter REST api通信。
如果我单独调用它，那么它在/server/目录中的server.js文件中工作得很好。如果我从一个observe内部包装或调用它，或者甚至调用一个从observe调用twit函数的函数，我就会得到错误。
例如，这在/server/server.js中可以很好地工作。
T.post('statuses/update', { status: 'hello world!' }, function(err, reply) {
console.log('error: ' +
浏览 0提问于2012-05-06得票数 2
回答已采纳
1回答
Visual Studio具有检查挂起的线程及其调用堆栈的能力。在给定纤程句柄的情况下，是否可以检查挂起的纤程的调用堆栈？
我们的目标是获得更多关于悬浮纤维的调试信息(并满足我的好奇心)。
从我最初的搜索来看，我并不认为这是件容易的事情(甚至是可行的)。欢迎提出建议。
浏览 4提问于2020-01-16得票数 0
我有下面的函数，我使用它作为windows纤程的入口点。
void foo(void*) {
for(int i =0; i < 10; ++i) { doStuff(); }
}
现在，我在for循环中调用main中的SwitchToFiber；如下所示。
int main() {
... create the fiber and stuff
for (int i = 0; i < 50; ++i) {
SwitchToFiber(foo_fiber_ptr);
// how do I tell if foo has al
浏览 7提问于2013-12-25得票数 0
2回答
嗨
我有一个使用专有数据集访问数据库的控件。该数据库是旧的基于ISAM的数据库。
该控件使用后台线程查询使用专有数据集的数据库。
一个表单上将有几个这样的控件，每个控件都使用自己的线程来访问数据，因为它们都需要同时加载。
专有dataset通过显示VCL TForm来处理并发性，通知用户正在打开的表已被其他用户锁定，并且dataset正在等待释放锁。
表单上有一个cancel按钮，可以让用户取消锁定等待。
问题是：
当从线程中使用专有数据集时，如果锁定等待窗体显示，应用程序将崩溃、挂起或给出一些错误。我怀疑这与VCL不是线程安全有关。
我已经通过同步Dataset.Open解决了这个问题，但是
浏览 2提问于2011-03-20得票数 0
回答已采纳
5回答
我知道使用协程作为基础和实现一个玩具调度器的基础知识。但我假设这是对异步调度器整体的过于简单化的看法。在我的思想中有一整套缺失的漏洞。
如何防止cpu运行空闲/等待的调度程序？一些纤程只是休眠，其他的则等待操作系统的输入。
浏览 2提问于2009-04-19得票数 10
回答已采纳
1回答
节点光纤是否阻塞？
、、、、
如果您使用在Node.js中运行I/O密集型任务，例如一些异步数据库操作，它会阻塞吗？
我还没有使用node-fibers b/c看起来--如果在处理HTTP请求的代码中使用它，在这个请求中运行一些长长的正常非阻塞的I/O代码--它现在将阻止其他请求访问您的应用程序。这是不是真的？一点关于它为什么是真/假的细节也会很有帮助。
浏览 6提问于2012-07-28得票数 3
回答已采纳
我在Ruby 1.9.2下运行这个代码片段：
require "eventmachine"
require "fiber"
EM.run do
fiber = Fiber.new do
current_fiber = Fiber.current
EM.add_timer(2) do
print "B"
current_fiber.resume("D")
end
Fiber.yield
end
print "A"
val = fiber.res
浏览 2提问于2012-10-04得票数 7
回答已采纳
2回答
我正在使用ntwitter模块从meteor应用程序内部访问推特的流node.js，但是当试图在回调函数内插入到集合中时，应用程序崩溃了：
twitter.stream('statuses/filter', {'track':'whatever'}, function(stream) {
stream.on('data', function (data) {
//logging the data coming back works fine
console.log(data);
//the
浏览 1提问于2013-01-12得票数 4
4回答
这个问题不是关于如何在Ruby 1.9.1中使用枚举器，而是我很好奇它们是如何工作的。下面是一些代码：
class Bunk
def initialize
@h = [*1..100]
end
def each
if !block_given?
enum_for(:each)
else
0.upto(@h.length) { |i|
yield @h[i]
}
end
end
end
在上面的代码中，我可以使用e = Bunk.new.each，然后使用e.next，e.next来获取每个连续
浏览 0提问于2009-09-16得票数 11
回答已采纳
1回答
我目前正在尝试(为了学习)理解Boost.Fiber库中的代码示例：
// Copyright Nat Goodspeed + Oliver Kowalke 2015.
// Distributed under the Boost Software License, Version 1.0.
// (See accompanying file LICENSE_1_0.txt or copy at
// http://www.boost.org/LICENSE_1_0.txt)
#include <chrono>
#include <
浏览 28提问于2019-11-20得票数 0
回答已采纳
我在使用Fibers/Metor.bindEnvironment()时遇到了困难。如果集合开始为空，我会尝试更新代码并插入到集合中。这一切都应该在启动时在服务器端运行。
function insertRecords() {
console.log("inserting...");
var client = Knox.createClient({
key: apikey,
secret: secret,
bucket: 'profile-testing'
});
console.log("created client
浏览 8提问于2013-11-15得票数 16
回答已采纳
1回答
我在C++/CLI中有一个使用非托管资源的类(本机线程的句柄(例如，来自CreateThread())和来自CreateFiber/ConvertThreadToFiber的纤程的LPVOID )。
根据我从得到的建议，我正在清理终结器(!Fiber())中的非托管资源，析构函数(~Fiber())正在调用终结器。
代码如下：
Fiber::~Fiber () {
this->!Fiber();
}
Fiber::!Fiber () {
if (thread!=NULL) {
delete thread;
thread=NULL
浏览 0提问于2011-12-30得票数 0
回答已采纳
我运行这段代码
class ttt {
public:
~ttt() {
LOG(INFO);
flush();
}
bool flush() {
//std::lock_guard<boost::fibers::mutex> lock(_mutex);
LOG(INFO);
_mutex.lock();
LOG(INFO);
auto ret = flush_nonlock();
LOG(INFO);
_m
浏览 4提问于2017-07-04得票数 0
1回答
我有这样的代码
var res = Fiber(function() {
var report;
// some asynchronous operations, result is in report
return report;
}).run();
在res中，我每次都有不确定的地方。我没有返回，而是尝试了Fiber.yield(报告)，但它没有帮助。该如何处理这些内容？顺便说一下，我用的是Meteor。
纤程内部函数运行良好，console.log返回良好结果
浏览 2提问于2015-09-09得票数 0
我在model.js中定义一个集合，如下所示：
People = new Meteor.Collection("people");
以下是main.js中的代码：
function test2(){
console.log(JSON.stringify(People.find().fetch()));
setTimeout(test2,5000)
}
if (Meteor.isServer) {
if(People.find().fetch().length === 0){
var tom = {name:"Tom",age:18};
浏览 2提问于2013-05-15得票数 1
回答已采纳
2回答
我有一个名为Foo的Class，它调用Bar的non-static方法barMethod()。Bar扩展了Fiber。
在barMethod()内部有一个对park()的调用。现在将驻留哪个Fiber？Foo实例还是Bar实例？
park()的签名(定义为static，这是我混淆的主要原因)：
public static void park()
throws SuspendExecution
如果答案是Foo (看起来是这样)，我如何驻留Bar？我主要打算suspend (park) Bar而不是Foo。
如果你给我一个关于如何驻留Bar实例的答案，那么请告诉
浏览 3提问于2016-05-12得票数 0
所以我和一位同事聊了聊，发现了，它描述了一个使用Fiber在C#中实现协程的方法。
本文中的Yield实现是针对.NET 1.1的，因此它早于.NET 2.0中出现的yield return语法。
乍一看，这里的实现可能更快，并且可以很好地扩展到多个CPU。
有人用过吗？
浏览 0提问于2009-12-10得票数 8
回答已采纳
我刚听说react-fiber准备好了。react和react-fiber之间的最大区别是什么？学习这种差异的全新概念值得吗？
浏览 1提问于2017-07-27得票数 72
对于节点中的npm模块，尝试让这些函数同步执行: saveFlightDetails需要saveFlight先完成，而saveItem又需要先完成...在循环迭代到下一组数据之前，这3个函数的每一组都需要完成。
我有一个for循环，里面有下面的代码，使用我的数据集，它迭代两次(2次飞行)。
function saveData(app, data, i){
var Item = app.get('models').Item;
var Flight = app.get('models').Flight;
浏览 1提问于2014-01-07得票数 0
1回答
当我在eventmachine中使用纤程模型调用外部API时，我遇到了问题。我在Sinatra中有以下代码：
get '/' do
conn = Faraday.new 'http://slow-api-call' do |con|
con.adapter :em_http
end
resp = conn.get
resp.on_complete {
request.env['async.callback'].call(resp)
}
throw :async
end
此外，我使用具有2个连接的:Event
浏览 32提问于2013-11-21得票数 2
2回答
尝试弄清楚如何通过套接字发送/读取数据。在远程服务器上，我创建了新的netcat -l 4444，并从本地发送文本数据echo "test" | netcat remote.host 4444。这总是工作得很好。
试图复制：
require "socket"
HOST = "remote.host"
PORT = 4444
ch_request = Channel(String).new
ch_response = Channel(String).new
spawn do
socket = TCPSocket.new(HOST, POR
浏览 24提问于2020-05-29得票数 0
回答已采纳
1回答
在没有IO的光纤之间循环
、、、
据我所知，crystal使用io循环Fibers，这意味着如果一根光纤在等待io，crystal将切换到另一根光纤。
如果我们产生两个纤程，但其中一个不使用io进行常量计算/循环，会发生什么呢？
例如，使用下面的代码，服务器不会响应任何http请求
spawn do
Kemal.run
end
spawn do
# constant computation/loop with no IO
some_func
end
Fiber.yield
# or sleep
浏览 0提问于2018-12-11得票数 4
有没有办法把一个线程的上下文(基本上是Thread.current散列)传递给另一个线程。
我正在从现有线程执行Thread.new，我希望这个新线程能够访问当前(即调用线程的)散列。
这是在ruby MRI 1.9.3/Rails 3.2.8环境中。
浏览 0提问于2012-11-15得票数 4
当通过websockets接收JSON数据时，我试图将这些数据提供给meteor中的mongodb。我可以很好地获取JSON数据，但是当我试图确定数据是否已经存在于数据库中时，我一直收到错误：“‘解析错误:没有纤程无法等待’‘。
binance.websockets.miniTicker(markets => {
//we've got the live information from binance
if (db.Coins.find({}).count() === 0) {
//if there's nothing in th
浏览 6提问于2018-04-13得票数 0
1回答
我正在尝试处理Ruby1.9中的新Fiber类，我读到Fibers (和协程)的一个更常见的应用程序是状态机。
不幸的是，我的Fiber-fu不是很好，所以我希望你们中的一个人能用Ruby展示一个使用Fiber的简单的状态机示例。
谢谢:)
浏览 1提问于2010-09-25得票数 2
1回答
在exec函数中填充了result，但它永远不会返回到主线程...我做错了什么？
var Fiber, exec, execSync;
exec = require("child_process").exec;
Fiber = require('fibers');
execSync = function(cmd) {
var cmdExec, final;
cmdExec = function(cmd) {
var fiber,
_this = this;
fiber = Fiber.
浏览 3提问于2012-09-14得票数 0
回答已采纳
2回答
什么是Meteor并发模型？
、、、、
我正在为Meteor应用程序编写服务器端逻辑，该应用程序必须更新内存中的状态以响应来自客户端的请求。这个应用程序需要强大的并发保证--特别是，我希望确保一次只执行一次更新。
我正在尝试弄清楚Meteor的并发模型是否支持这一点。文档提到Meteor是多线程的(这将是一个问题)，但在搜索之后，我得到的印象是Meteor实际上使用了纤程(显式调度的线程)。如果这是真的，那么只要我的代码中需要原子运行的部分不进行任何Meteor调用(这涉及到IO，从而产生执行锁)，我就是安全的。
真的是这样吗？在哪里可以找到有关Meteor并发模型的更多信息？
浏览 1提问于2013-08-11得票数 14
1回答
好的，所以我正在开发一个多人游戏，使用: Node.js，Sockets.io & Redis
无论如何，玩家可以创建游戏，然后开始游戏，现在游戏逻辑需要每10秒更新一次，所以这是通过调用一个方法来完成的，该方法将通过setTimeout调用自身每x秒。
我担心的是，当连接的客户端连接，创建游戏(启动setTimeout周期)，然后断开连接时，这将停止任何setTimeout，从而终止所有其他玩家的游戏。即使在用户断开连接时setTimeout一直被触发，理想情况下我仍然希望对用户的socket.io连接单独运行此命令。
在node.js中有没有一种简单的方法来启动独立的进程/线程？(
浏览 2提问于2012-03-30得票数 0
回答已采纳
1回答
public bool HasItemsFromPropertySet(InfoItemPropertySet propertySet, CompositeInfoItem itemRemoved)
{
var itemAndSubItems = new InfoItemCollection();
if (itemRemoved != null)
{
itemAndSubItems.Add(itemRemoved);
//foreach (InfoItem item in itemRemov
浏览 9提问于2012-04-19得票数 9
回答已采纳
根据的说法，外部迭代器过去很慢，但现在更快了。这是只在YARV (基于C的ruby 1.9实现)中可用的改进，还是在ruby 1.8.7的基于C的实现中也可用？
另外，enum_for依赖于外部迭代器吗？
浏览 5提问于2010-06-17得票数 2
回答已采纳
2回答
使用等待外部异步
、、、、
有没有办法让javascript await关键字在async函数之外工作？我希望能够冻结整个调用堆栈(而不仅仅是async函数的其余部分)，以便在特定的promise返回值时恢复。不幸的是，像这样强大的await目前还没有实现。我试图让工作，但由于我的自定义加载器和动态函数，不幸的是这是不切实际的。
浏览 1提问于2017-03-10得票数 2
回答已采纳
我正在构建一个与twitter api挂钩的流星应用程序，但到目前为止我还没有幸运地让它正常工作。我使用twit包在服务器端进行调用，它将数据记录到服务器控制台，但是当客户端控制台记录数据时，没有数据。
客户端不会抛出错误，它会在else语句中为result参数运行console.log，但它是未定义的。这就好像结果回调是在数据返回之前运行的，但我对Meteor.call方法的理解是，它应该等到从服务器收到反馈后才运行。
我在这里做错了什么？
if (Meteor.isClient) {
Template.hello.greeting = function () {
return
浏览 1提问于2014-03-18得票数 0
在.NET BCL中，有一个CurrentThread和一个ProcessThread对象。它们之间的区别是什么？
谢谢
浏览 0提问于2010-06-01得票数 1
回答已采纳
1回答
纤程/协程vs定界延拓
、、、
所以我在这里读到了一篇关于并发工作窃取数据的论文：。他们提到了“子窃取vs延续窃取”，他们说，子窃取可能需要无限的堆栈空间来容纳尚未执行的任务，而不像延续窃取，这是P=#processors的一个恒定因素。
我有一个关于纤维/协程和定界延拓之间的区别的理论问题。首先，我承认协程和纤程几乎是等价的，但是纤程也等同于延续吗？我暗自怀疑我将要实现的东西是根本错误的(即。用纤程替换线程，而不是真正实现一个不需要无限内存的版本)。
浏览 7提问于2018-06-26得票数 1
def index
p "INDEX, #{Fiber.current.object_id}" # <- #1
EventMachine.run {
http = EventMachine::HttpRequest.new('http://google.com/').get :query => {'keyname' => 'value'}
http.errback { p "Uh oh, #{Fiber.current.object_id}"; EM.stop } # &
浏览 8提问于2013-07-22得票数 0
我有一个简单的Lua脚本：
while ( i < 500000 ) do
redis.call("zadd", 'test1', i, i)
redis.call( "expire", 'test1', 600 )
i = i + 1
end
local res = redis.call("zrange", "test1", 0, 500000 )
for k,a in pairs(res) do
redis.call("zadd", &#
浏览 2提问于2012-06-29得票数 1
回答已采纳
Enumerator实例如何跟踪其内部状态？以下面的代码片段为例：
enum = Enumerator.new do |yielder|
yielder << 1
yielder << 2
yielder << 3
end
puts enum.next # => 1
puts enum.next # => 2
enum.rewind # start again
puts enum.next # => 1
当在enum上调用诸如each之类的迭代器方法时，每次调用yielder#<< (或yielder#yield)
浏览 10提问于2017-07-20得票数 1
回答已采纳
1回答
我有下面的代码： import zio._
import scala.concurrent.Future
case class AppError(description: String) extends Throwable
// legacy-code imitation
def method(x: Int): Task[Boolean] = {
Task.fromFuture { implicit ec => Future.successful(x == 0) }
}
def handler(input: Int): IO[AppError, Int] = {
for
浏览 19提问于2020-07-12得票数 2
回答已采纳
我正在接触Meteor的HTTP方法。
作为测试，我在服务器上使用一个方法访问Twitter的api，如下所示：
"twitter_user": () ->
Meteor.http.get("https://api.twitter.com/1/users/show.json", {screen_name:"ppedrazzi"})
在客户端，我按如下方式调用该方法：
twitterUser = Meteor.call("twitter_user")
当尝试访问twitterUser对象时，它显示为未定义。我希望能够
浏览 0提问于2013-04-13得票数 2
回答已采纳
2回答
纤维对我来说是一个相对较新的概念。我知道每根光纤的堆叠大小被限制在4kB，我一直在读，我应该“小心”这一点。这种限制在现实世界中的后果到底是什么？
编辑：
看起来这个4kB的限制并不是一个很大的障碍，它需要在纤程内部使用大量的局部变量(4,045)才能引发SystemStackError。
count = 0
loop do
count += 1
puts count
varlist = String.new
count.times do |i|
varlist += "a#{i} = 1\n"
end
s = "fiber = Fibe
浏览 4提问于2012-11-30得票数 12
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
