草庐IT

多线程通信

全部标签

docker - 如何让两个运行 flask 服务和 golang 服务的 docker 容器相互通信?

我有一个flask服务通过docker-compose在端口5000上运行。同样,我有一个不同的go服务通过另一个docker-compose在端口8000上运行。Golang服务需要调用在5000上运行的flaskAPI。我是在让go服务调用flask服务时遇到麻烦。我尝试添加docker-network但失败了。与单个docker-compose相比,通过不同的docker-compose运行这两种服务的优缺点是什么?(顺便说一句,我无法在单个docker-compose中成功运行它们)。dockerpsrunningboththecontainers.FlaskDocker组合v

multithreading - 是否应该在长时间运行的进程中留下空闲线程?

我正在创建一个旨在长期运行并监听工作的go程序。当它收到请求时,它会在进程队列上运行工作。我是golang和系统编程的新手,所以我的问题是:我应该在程序启动时启动进程队列(有多个空闲工作线程)(它们会一直坐在那里直到工作开始)还是应该我在工作到达时启动它们并在完成时关闭它们?我不清楚多个空闲线程对整个系统的影响,但我假设因为它们是空闲的,所以在工作到达之前不会有任何影响。也就是说,我想确保我的程序是一个“好邻居”并且尽可能高效。--编辑--澄清一下,“进程池”是一组在channel上等待工作的workergoroutines。它们应该在工作到达时启动/停止,还是在程序启动时启动并等待工

go - 同一网络中的应用程序和服务器之间的通信

关闭。这个问题需要更多focused.它目前不接受答案。想改进这个问题吗?更新问题,使其只关注一个问题editingthispost.关闭3年前。Improvethisquestion我正在开发将在kubernetes上运行的CI/CD工具。该应用程序将负责创建一个k8s作业对象,该对象将被视为一个slave以运行管道。图像,slave将运行完全取决于用户,所以我无法控制它,除了它会在与CI/CD应用程序相同的本地网络中运行。我的问题是;在这种情况下,如何使CI/CD工具与从属之间进行通信?为了为此添加更多上下文,我想创建类似于Jenkins的东西。Jenkins与kubernetes

go - 为什么在 Ubuntu 上无限执行例程后不会从线程打印

我有一个在Ubuntu上看起来像这样的go程序packagemainimport("fmt""time")funcmain(){count:=2fori:=0;i我的想法是调用go例程两次,然后在每次运行go例程时,我会等待1秒,然后打印"helloworld"但是这个程序在ubuntu上的输出是no输出。它似乎适用于OSX这是OSX的输出:在Ubuntu上输出如下所示这种疯狂有原因吗?我是否做错了什么,可能在两个不同的操作系统上有不同的处理方式?为什么Ubuntu没有显示输出? 最佳答案 忙等待for{}循环不会屈服于调度程序,因

Go 线程 - 暂停执行

我有两个执行线程,比如,Routine1{//dosomething}Routine2{//dosomething}是否可以将例程1中的例程2的执行暂停几秒钟,这怎么可能? 最佳答案 不可能从一个goroutine控制另一个goroutine的执行。Goroutines是合作的。它们不会相互支配。您可以做的是在例程2中放置点,以检查是否允许继续进行。比如//dostuffselect{case然后例程1可以告诉例程1可以向例程2发送一个信号,告诉它等待:wait为什么要暂停goroutine?这可能有助于更好地回答您的问题。最好从你

dictionary - golang线程安全映射, channel 作为线程安全的值

我用this作为并发映射,缓冲channel作为线程安全的映射值(作为队列工作),当测试使用10个goroutines时,从channel获得的值与发送的值不同,有什么建议吗?packagemainimport"fmt"import"github.com/streamrail/concurrent-map"funcmain(){testmap:=cmap.New()fmt.Println("SyncMapNew:",TestInParallel(&testmap,10))}funcTestInParallel(g*cmap.ConcurrentMap,nint)time.Duratio

multithreading - Go运行时使用的线程数

Go运行时(调度程序、垃圾收集器等)可以使用多少个线程?例如,如果GOMAXPROCS是10,那么运行时将使用多少内核线程?编辑:我正在阅读therationale在Go1.5中将GOMAXPROCS更改为runtime.NumCPU()。有一句话声称“由于运行时的并行性,尤其是垃圾收集器,单goroutine程序的性能可以通过提高GOMAXPROCS来提高。”我真正的问题是:如果我有一个在具有CPU配额的Docker容器中运行的单goroutine程序,为了获得最佳性能,我需要的最少逻辑处理器数量是多少? 最佳答案 没有直接的相关

multithreading - Go:稀疏数组读写的线程安全并发问题

我正在用Go编写一个搜索引擎,其中我有一个单词的倒排索引到每个单词的相应结果。有一套单词字典,所以单词已经转换为StemID,它是一个从0开始的整数。这允许我使用指针slice(即稀疏数组)将每个StemID映射到包含该查询结果的结构。例如。varStemID_to_Index[]*resultStruct。如果aardvark为0,则指向aardvark的resultStruct的指针位于StemID_to_Index[0],这将如果当前未加载该词的结果,则为nil。服务器上没有足够的内存来存储所有这些,因此每个StemID的结构将被保存为单独的文件,这些可以加载到StemID_to

go - 线程从 java 到 go

我怎样才能将下面的代码翻译成Go,你可以在下面看到我的尝试,但是因为我在等待按键输入,所以代码总是返回20000,其中java会输出不同的结果。我知道两者都有竞争条件,但我只想知道翻译。JavapublicclassCounting{publicstaticvoidmain(String[]args)throwsInterruptedException{classCounter{privateintcount=0;publicvoidincrement(){++count;}publicintgetCount(){returncount;}}finalCountercounter=ne

Golang 中的多线程套接字连接

背景我正在使用Golang创建一个聊天室服务器。每次客户端连接到服务器时,我都会将客户端函数作为一个新线程启动,这样每个客户端都会得到一个被监听的线程。我能够基于thistutorial创建一个简单的客户端服务器连接,但现在我正在尝试为多个客户端创建连接,以便他们可以向聊天室发送消息。代码解释关注thistutorial,看起来我可以使用gofunc()创建线程并等待通过包含channel()建立连接。我在调用用户函数之前将一个bool值传递到channel中,因为用户函数将永远运行并且我想建立其他客户端连接。每个客户端连接都将运行用户函数。问题我不知道如何将用户连接变量传递给我的其他