Tag: channel
Eine Mitteilung Konstrukt ermöglicht das senden von Objekten zwischen Ausführungs-threads.
Sie können und sollten diesen tag beziehen sich entweder auf die generische Programmierung Vorstellung oder die spezifische Implementierungen in verschiedenen Sprachen oder Bibliotheken. Im letzteren Fall vergessen Sie nicht, fügen Sie den entsprechenden tag.
2
Antworten
Ich würde gern die Google-Analytics-API, um die Daten angezeigt, die auf den Erwerb Übersicht über die Webseite. Vor allem, ich brauche, um die Sitzungen (früher besuchen) break Default-channel-Gruppierung : Direkt, Organische Suche, Referral -, Social, Paid Search,
2
Antworten
Bin ich mit Spring-Integration-Umfrage ein Verzeichnis für eine Datei, ein Prozess diese Datei in eine service-Klasse, schreiben Sie diese Datei, um eine Ausgabe-Verzeichnis und löschen Sie dann die ursprüngliche Datei. Ich habe die folgende XML-Konfiguration: <int-file:inbound-channel-adapter id="filesInChannel"
2
Antworten
Nach (kurzer) Prüfung der Go Sprache spec, effektiv Gehen, und die Gehen-Speicher-Modell, ich bin immer noch ein wenig unklar, wie es zu Gehen-Kanäle arbeiten unter der Haube. Welche Art von Struktur sind Sie? Sie wirken wie eine
2
Antworten
Beim Blick durch einige Go-code habe ich Folgendes gefunden: ch := make(chan int) Ich blickte in ein online-tutorial, wie Sie Gehen-Kanäle arbeiten: https://tour.golang.org/concurrency/2 Aber ich finde dieses Beispiel unklar. Kann mir jemand eine einfache Erklärung und ein
3
Antworten
Habe ich eine Scheibe von ganzen zahlen, die manipuliert werden, die gleichzeitig: ints := int{1, 2, 3, 4, 5, 6, 7, 8, 9, 10} Ich bin mit einer gepufferten Kanal als semaphore, um eine Obere Grenze der
2
Antworten
Ich versuche zu verstehen, Gehen Sprache. Ich habe versucht, zwei goroutines Kette, die zwischen Ihnen fließen über zwei Kanäle: func main() { c1 := make(chan int) c2 := make(chan int) go func() { for i := range
4
Antworten
Ich Lerne das Gehen, die Sprache. Hier ist ein Beispiel, das ich begegnet bin. Kann mir bitte jemand erklären, was hier passiert? package main import "time" import "fmt" func main() { c1 := make(chan string) c2 :=
1
Antworten
Ich bin mit golang zu implementieren eine einfache event-driven-Arbeiter. Es ist so: go func() { for { select { case data := <-ch: time.Sleep(1) someGlobalMap[data.key] = data.value } } }() Und die main-Funktion erstellen mehrere goroutines, und
1
Antworten
Ich habe eine client-app, die versucht alle 10 Sekunden eine Nachricht zu senden, über einen WCF-service. Diese client-app wird auf einem computer an Bord eines Schiffes, von denen wir wissen, haben fleckige internet-Konnektivität. Ich möchte mich für
4
Antworten
Ich versuche zu nennen, einen WCF-service (gehostet in einem Windows-Dienst nicht IIS) und erhalte die folgende Fehlermeldung: Die maximale Größe einer Nachricht Quote für eingehende Nachrichten wurde überschritten für den remote-Kanal. Sehen server-logs für weitere details. Habe
1
Antworten
Möchte ich, um nur den ersten Kanal (Blau) in der BGR-Bild und dann auf Festplatte zu speichern. Wenn ich mit cv2.split() ist alles ok >>> import cv2 >>> a = cv2.imread("/home/s18/theVIDEO/1_resized.jpg") >>> b = cv2.split(a)[0] >>> type(b)
3
Antworten
Ich bin mit RXTX zum Lesen von Daten von einem seriellen port. Die Lesung ist getan innerhalb ein thread erzeugt, in der folgenden Art und Weise: CommPortIdentifier portIdentifier = CommPortIdentifier.getPortIdentifier(port); CommPort comm = portIdentifier.open("Whatever", 2000); SerialPort serial
1
Antworten
Warum Gehen Panik auf das schreiben zu einem geschlossenen Kanal? Während die value, ok := <-channel idiom für das Lesen von Kanälen, und so ist die ok-Ergebnis getestet werden kann, zur Kollision mit einem geschlossenen Kanal: //reading
2
Antworten
Ist es möglich, pass Mauszeiger über Kanal lang gehen? Ich übergeben zu müssen, struct, haben Veränderungen in der it und haben diese änderungen in die gleiche Funktion aus, wo struct übergeben wurde? Versuchte ich chan <- &data
2
Antworten
Bin ich versucht zu implementieren, um einen reconnect Logik für einen wcf-client. Ich bin mir bewusst, dass Sie haben, um eine neue Kanal nach dem aktuellen channel betrat den fehlerhaften Zustand. Ich Tat dies in einem channel
2
Antworten
Erstellen einer Reihe von Kanälen? Zum Beispiel: ersetzen Sie die folgenden fünf Zeilen mit einer Reihe von Kanälen, mit einer Größe von 5: var c0 chan int = make(chan int); var c1 chan int = make(chan int);
1
Antworten
Habe ich gelesen.wav-Datei-format durch googeln,was ich konnte, Figur war, die Rahmen sind aus Proben(von einer definierten bit-Tiefe) und eine stereo-wav-Datei hat eine mehrere der so genannten Kanäle.... Die Verwirrung ist ob ein Kanal besteht aus frames? Tun
2
Antworten
Ich versuche eine Nachricht zu senden, um einen bestimmten Kanal mit meiner Zwietracht bot, der in mehreren Servern. Ich will den bot zu Holen, auf einer Nachricht von einem server und senden eine Nachricht zu meiner persönlichen
3
Antworten
Brauche ich eine riesige Menge von goroutines und warten auf Ihre Kündigung. Die intuitive Art und Weise, scheint ein Kanal zu warten, bis alle fertig sind : package main type Object struct { //data } func (obj
2
Antworten
In Golang, wenn ein Kanal channel ist geschlossen, ich kann immer noch Lesen, es mithilfe der folgenden syntax ein, und ich kann testen ok zu sehen, wenn es geschlossen ist. value, ok := <- channel if !ok
8
Antworten
Wünsche ich mir eine go-routine hören auf beiden Kanälen blockiert, wenn beide Kanäle entwässert werden. Allerdings, wenn beide Kanäle die Daten enthält, möchte ich einen abgelassen werden, bevor die anderen behandelt wird. Im Beispiel unten ich wünschte,
2
Antworten
Schreibe ich eine expect-Skript, das ssh-Verbindung auf mehrere IP-Adressen testen Sie Ihre Konnektivität. Ich möchte zu eine "legt" - Anweisung zu schreiben, die das Ergebnis der einzelnen Tests in einer Datei auf dem Rechner nach dem aufrufen
2
Antworten
Auf dem Nexus 7 (4.3), und nicht auf mein älteres Gerät, den LG Optimus 3d (Android 2.2), wenn ich HttpPost, bekomme ich diese E/InputDispatcher﹕ Kanal '4273f7b0 ... MainActivity (server)' ~ Kanal ist unrecoverably fehlgeschlagen gebrochen und entsorgt
3
Antworten
Ich versuche, eine Verbindung zu einem SFTP remote-server mit JSCH library version 0.1.49. Jedes mal, wenn ich das Programm starte, erhalte ich den folgenden Fehler : Initializing... Connection to SFTP server is successfully com.jcraft.jsch.JSchException: Unable to connect
1
Antworten
Meine JMS-client eine Verbindung zu ein Fehler in WMQ durch JNDI. Die initial context factory ist com.ibm.mq.jms.context.WMQInitialContextFactory. Derzeit, bei der ein Fehler in WMQ Seite gibt es eine queue-manager namens TestMgr. Unter diesem queue-manager erstellte ich zwei
1
Antworten
Ich bin der Implementierung des facebook-login bei meiner website, die in form von mysite.anotherdomain.org . Ich habe alles erklärt in der Dokumentation der Javascript SDK, aber, da ich einige Probleme haben, Frage ich mich, ob die Fehler
1
Antworten
Ich bin immer noch irgendwie der Umhüllung meinem Kopf, um Schnittstellen innerhalb golang. Ist es möglich, mehrere unterschiedliche Typen über eine einzige, "generic" - Kanal? Hier ist ein sehr einfaches Beispiel: http://play.golang.org/p/7p2Bd6b0QT. InformationsquelleAutor ben lemasurier | 2014-02-28
3
Antworten
RabbitMQ ist Channel#basicConsume Methode gibt uns die folgenden Argumente: channel.basicConsume(queueName, autoAck, consumerTag, noLocal, exclusive, arguments, callback); Geben uns die Möglichkeit zu sagen, RabbitMQ genau die Warteschlange, die wir konsumieren wollen. Aber Channel#basicPublish hat keine solche äquivalenz: channel.basicPublish(exchangeName,
2
Antworten
Ich bekomme diese Fehlermeldung, wenn ich bin, oft senden einige e-Mails an eine Liste von Benutzern. Sagen, es sendet 10 mails und 1 gibt einen Fehler, dann sendet ein paar mehr mails und gibt den gleichen Fehler.
2
Antworten
Meine Anforderung ist wie folgt: Ich habe den login auf Unix-Rechner mit meinen Zugangsdaten und einmal einloggen, das muss ich sudo für die verschiedenen Benutzer. Einmal sudo erfolgreich ist, habe ich zum aufrufen von shell in nohup.
3
Antworten
Ich kam vor kurzem in diesem Artikel, die eine nette Einführung in die memory-mapped-Dateien und wie kann Sie geteilt werden zwischen zwei Prozessen. Hier ist der code für einen Prozess, der liest in der Datei: import java.io.File;
3
Antworten
In seinem Dokument, Facebook empfehlen, eine Kanal-Datei für Ihr JavaScript-SDK. Meine Frage betrifft die kleinen Details darüber, wie diese Datei zu erstellen. Es ist klar, dass ich erstellen muss und die HTML-Datei mit der Zeile <script src="//connect.facebook.net/en_US/all.js"></script>
4
Antworten
Bin ich neu zu gehen, und ich bin versucht, zu erstellen eine einfache chat-server, wo die clients können broadcast-Nachrichten an alle verbundenen clients. In meinem server, ich habe eine goroutine (unendliche Schleife) akzeptiert die Verbindung und alle
3
Antworten
Kürzlich brauchte ich zum installieren PyPdf2 zu einem meiner Programme mit Anaconda. Leider habe ich versäumt, aber die URLs Hinzugefügt wurden Anaconda Umgebung zu verbieten, die updates aller Conda Bibliotheken. Jedes mal, wenn ich versucht, zu aktualisieren,
3
Antworten
In meinem C# (3.5) Anwendung, die ich brauche, um die durchschnittlichen Farbwerte für rot -, grün-und blau-Kanälen eines Bildes. Vorzugsweise ohne Verwendung einer externen Bibliothek. Kann das getan werden? Wenn ja, wie? Vielen Dank im Voraus. Versuchen,
4
Antworten
Sah ich einige code in diesem link, und verwirrt:http://www.darkcoding.net/software/go-lang-after-four-months/ Was bedeutet der zweite Wert(ok)? for self.isRunning { select { case serverData, ok = <-fromServer: //What's the meaning of the second value(ok)? if ok { self.onServer(serverData) } else
3
Antworten
Suche ich durch redis command-Liste. Ich konnte nicht finden, dass der Befehl, um alle verfügbaren Kanäle in redis pub/sub. In den meteor-server, der entsprechende Befehl ist LISTCHANNELSwo es listet alle bekannten Kanäle, die Anzahl der Nachrichten, die
3
Antworten
Las ich einige code gehen und sagen, ein paar verschiedene Möglichkeiten, um pass go-Kanäle. Vielleicht sind Sie das gleiche, aber ich Frage mich, ob es einen Unterschied, da ich nicht finden konnte, Dokumentation online: 1) func serve(ch
2
Antworten
Sorry für die Anfänger-syntax Frage. Wie zu tun, wie erstellen Sie ein array der Kanäle gehen? var c0 chan int = make(chan int); var c1 chan int = make(chan int); var c2 chan int = make(chan int);
4
Antworten
Kann jemand empfehlen, wie ich das einbetten eines youtube-Kanal in eine Webseite - ich bin immer widersprüchliche Informationen von verschiedenen Standorten, idealerweise mit dem custom-player, wenn möglich? Dank InformationsquelleAutor der Frage Zabs | 2012-02-09
3
Antworten
Haben wer ZmqSocket.js erfolgreich? Ich würde gerne wissen, wie kann es verwendet werden, um einen sicheren Kanal zwischen dem browser und einem zeromq server-app. Gibt es andere/bessere Möglichkeiten für einen solchen Anwendungsfall? InformationsquelleAutor der Frage Carlo Pires
3
Antworten
Ich habe gerade gelesen RabbitMQ-Java-API-docsund fand es sehr informativ und geradlinig. Beispiel für das einrichten eines einfachen Channel für die Veröffentlichung/konsumieren ist sehr einfach zu Folgen und zu verstehen. Aber es ist ein sehr einfaches/einfaches Beispiel, und
3
Antworten
Also habe ich beschlossen, um die Leistung ein bisschen in meinem WCF-Anwendung und versuchen Sie die cache-Kanäle und die ChannelFactory. Es gibt zwei Fragen, die ich über all dies, die ich brauche, um aufzuräumen, bevor ich loslege.
6
Antworten
Wie kann ich überprüfen, ob ein Kanal einen Wert hat, der für mich zu Lesen? Ich nicht wollen, zu sperren, wenn das Lesen eines Kanals. Ich möchte sehen, ob es einen Wert hat. Wenn es funktioniert, werde
2
Antworten
Gegeben das folgende einfache Programm Gehen package main import ( "fmt" ) func total(ch chan int) { res := 0 for iter := range ch { res += iter } ch <- res } func main() {
5
Antworten
http://play.golang.org/p/vhaKi5uVmm package main import "fmt" var battle = make(chan string) func warrior(name string, done chan struct{}) { select { case opponent := <-battle: fmt.Printf("%s beat %s\n", name, opponent) case battle <- name: //I lost :-( } done
2
Antworten
Wir haben einen WCF-Dienst, die, das wir verbrauchen, aus einer web-app. Der client wir benutzen die generiert wurde, mithilfe von Visual Studio "Add Service Reference" - option. Da es eine web-app, und da die Art der app
4
Antworten
Ist es OK zu verlassen, Gehen Sie Kanal für immer geöffnet werden (niemals in der Nähe der Kanal), wenn ich nie überprüfen, die für seinen Zustand? Wird es führen, um memory leaks? Ist der folgende code OK?
2
Antworten
Ich versuche zu schaffen, einen asynchronen Kanal, und ich habe auf der Suche bei http://golang.org/ref/spec#Making_slices_maps_and_channels. c := make(chan int, 10) //channel with a buffer size of 10 Was bedeutet es, dass der Puffer ist 10? Was genau
2
Antworten
Habe ich eine Node.js web-server, läuft ein socket-server auf der Oberseite, die erstellt wurde, mithilfe Socket.io. Im Grunde funktioniert dies. Was ich jetzt erreichen möchte ist, dass die clients, die eine Verbindung Gliedern sich in Gruppen. So