channel

2열

1답변

프로파일 링을 위해 채널 쓰기/읽기를 기다리는 goroutines 수 얻기 (프로파일 링을 위해)

내 응용 프로그램을 프로파일 링하기 위해 채널에 쓰거나 읽는 것을 기다리는 goroutine의 수를 알고 싶습니다. reflect package과 관련된 내용을 찾을 수 없습니다. 물론 명시적인 카운터를 유지할 수는 있지만 golang 런타임에이를 알리 길 기대합니다. 따라서 휠 재발생을 피하려고합니다. 그래서 수동으로 카운터를 유지하지 않고도 그렇게 할

go profiling channel goroutine 2017-09-22

---

1열

1답변

골란 동시 컨텍스트에서 채널의 올바른 사용 이해

나는 웹 사이트에서 크롤링하는 간단한 웹 크롤러 인 go 프로젝트를 작성 중입니다. goroutines 및 채널과 같은 동시 기능을 실험하고 싶습니다. 그러나 내가 그것을 실행할 때 그것은 통과하지 않았다. 마치 아무 일도 일어나지 않는 것처럼 보입니다. 나는 무엇이 잘못되었는지 전혀 모른다. 누군가 나를 위해 그것을 지적 할 수 있습니까? 채널 논리를 제

go channel 2017-09-24

---

0열

1답변

netty4.x의 channelActive() 메소드에서 URL을 얻을 수있는 방법

URL은 http://url.com/username입니다. 클라이언트가 서버에 연결할 때 channelActive에서 사용자 이름을 확인해야합니다. 가능합니까? 감사 public class Handler extends ChannelInboundHandlerAdapter{ @Override public void channelRead(Chan

java netty channel 2017-09-27

---

8열

1답변

교착 상태를 달성하려고 시도하는 동안 0이있는 무한 루프

다음 코드는 계속 인쇄합니다. 0. 나의 이해에서 package main import ( "fmt" ) func main() { c := make(chan int) go func() { for i := 0; i < 10; i++ { c <- i // INPUT } close(

go channel 2017-09-30

---

0열

1답변

팬을 에뮬레이션하려고 할 때 데드락을 얻으려고 계승 계산으로 팬 아웃

계승 문제가있는 fan in - fan out 패턴을 사용하려고합니다. 그러나 나는 받고있다 : fatal error: all goroutines are asleep - deadlock! 그리고 교착 상태에 대한 이유를 알 수 없다. 팬 인 팬 아웃 패턴을 사용하여 100 개의 숫자에 대한 계승을 동시에 계산하려고합니다. package main im

go concurrency deadlock channel 2017-10-01

---

-1열

1답변

"잠 들어있는"고 루틴을 모두 닫으려면 어떻게해야합니까?

나는 goroutine가 for 루프에서 실행이 : func main(){ for _, i := range x{ go httpRequests(i, ch) } for i := range ch{ print i } } func httpRequests(i, ch){

go channel goroutine 2017-05-06

---

1열

1답변

여러 나는 이런 식으로 한 번에 여러 구독에 대한 사용자를 구독 할 수 있습니다 레일 채널에서 피닉스 채널

에서 한 번에 가입 : def subscribed [1, 2, 3].each do |subscription| stream_for subscription end end 이제 사용자는 세 가지 구독 "my_channel : 1"있다 "my_channel : 2 ","my_channel : 3 ". 이런 식으로 내 사용자를 구독하

websocket elixir phoenix-framework channel 2017-05-09

---

1열

1답변

time.After() 대신 time.Sleep()을 사용하여 인터럽트 가능 일시 중지를 얻는 방법

정기적으로 외부 사서함에서 메시지를 확인하고 메시지를보고 끝내기 위해 사용자보기가있는 프로그램이 있습니다. 프로그램. 는이 package main import ( "log" "time" ) func main() { log.Println("Hello, playground") quit := make(chan bool

go concurrency sleep scheduler channel 2017-05-10

---

1열

1답변

Python Pika가 iddle에서 채널 연결을 끊습니다.

iddle 채널에 대한 시간 제한을 설정하는 방법을 이해하는 데 문제가 있습니다. 나는이 대답을 찾을 : Stop channel.basic_consume if the connection is idle/Not consuming from long time 을하지만 변수 timer_id 내 ON_MESSAGE 메서드 내 범위에서 가져옵니다. 주어진 시간에 메시지

rabbitmq channel pika 2017-05-19

---

0열

1답변

UnresolvedAddressException 소켓 채널

내 컴퓨터와 원격 서버 간의 소켓을 만들려고 해요하지만이 수행 할 때 내가 UnresolvedAddressException 오류를 받고 있어요 : 왜이 ​​ InetSocketAddress hostAddress = new InetSocketAddress("http://www.google.com", 80); SocketChannel serverCha

java sockets nio channel 2017-05-21

---