로그 메시지를 무작위로 생성하고 생성 된 후 로그에 기록하기 전에 시간 소인별로 정렬해야합니다. 나는 내 타임 스탬프에 따라 정렬 할 수 있도록 sort 라이브러리의 sort.Interface 부분을 활용하고 있습니다. 팬 - 인 동시성 (fan-in concurrency) 디자인을 사용하고 있으므로 정렬 기능은 goroutines의 모든 로그 메시지를 집
반응식 골란 구현을 구현하려고했습니다. 나는 관찰자들의 배열을 가지고있다. 그들은 단지 채널의 무리입니다. 모든 것은 다른 코드가 구독 및 구독 취소 할 수있는 패키지로 캡슐화됩니다. 주문이 생성되면 변경 사항이 적용됩니다. 하지만 방법으로 채널 수신을 등록하지 못했습니다. 나는 시험, 위의 코드를 인쇄 아무것도하지만 주석 라인 경우를 수행 할 때 pack
NIO에서 Java 선택기를 사용하고 있습니다. 선택 키/관심사 키를 특정 채널 및 선택기에 등록합니다. 자, 내 요구 사항은 특정 선택 자에 대해 둘 이상의 관심 분야 세트를 갖는 것입니다. try {
Selector selector = Selector.open();
ServerSocketChannel channel = ServerS
Backendless에는 채널을 구독하고 들어오는 메시지를 수신 할 수있는 방법이 있습니다. Backendless.Messaging.subscribe(
channelName, //some random name
500, //500 ms interval for polling
new AsyncCallback<List<
나는 clojure.async를 사용하여 소켓 읽기/쓰기를 추상화하는 몇 가지 기능을 작성하고 있습니다. 내 의도는 채널에 값을 써서 쓸 수 있고 읽을 채널에서 값을 팝핑 할 수 있다는 것입니다. 이 방법으로 사용자는 Reader s/Writer 초를 걱정할 필요가 없습니다. 아래 코드는 루프의 소켓에서 읽은 내용을 채널로 전달합니다. 채널을 읽을 수 있도
나는 golang 채널을 처음 사용하며 설명 할 수없는 이상한 동작이 있습니다. REST 명령을 받고 있는데 해시 함수를 계산하려고합니다. 다음과 같이 내가이 클래스를 사용 BodyChannel chan []byte : func (self *WriterToHash) Write(p []byte) (n int, err error) {
n=len(p)
간단한 작업자 풀을 구현하고 문제를 계속 실행하려고합니다. 내가하고 싶은 일은 더 많은 일을하기 전에 일정량의 일을하는 정해진 수의 근로자를 확보하는 것뿐입니다. 내가 비슷합니다 사용하고 코드 : jobs := make(chan imageMessage, 1)
results := make(chan imageMessage, 1)
for w
Run() 메서드가있는 Hub 구조체가 고유 한 goroutine에서 실행됩니다. 이 방법은 수신 메시지를 순차적으로 처리합니다. 메시지는 여러 프로듀서 (개별 goroutines)로부터 동시에 도착합니다. 물론이 작업을 수행하려면 channel을 사용합니다. 그러나 이제 interface 뒤에 Hub을 숨기고 구현에서 선택할 수 있습니다. 따라서 chan
Go lang에서 데칼 한 채널을 두 번 시작할 수 있습니까? main 함수에서 package main
import (
"fmt"
)
func emit(c chan string) {
words := []string {"The", "quick", "brown", "fox"}
for _, word := range words