Tag: nonblocking
Non-blocking-Modus I/O entweder überträgt sich mindestens ein byte oder kehrt sofort mit einem Fehler oder das Ende des Stroms. Nicht-blockierende algorithmen beziehen sich auf die Nutzung von Parallelität ohne den üblichen wechselseitigen Ausschluss primitive, die garantiert, dass thread-Operationen nicht blockieren. Dies erfolgt normalerweise mit atomarer Wert ändern (erhöhen/verringern) und/oder Lesen (vergleichen-und-exchange -) Operationen.. Es ist nicht klar, welche diesen tag vorgesehen ist.
python epoll und nicht blockierende
1 Antworten
einfache client-server-socket-Studium code,den der server-Ende: import socket,select,time s = socket.socket() host = socket.gethostname() port = 1234 s.bind((host,port)) s.listen(50) s.setblocking(0) # (1) fdmap = {s.fileno():s} p = select.epoll() p.register(s) while True: events = p.poll() for fd,event in events:
PyAudio Ansprechende Aufnahme
2 Antworten
Ich habe gesehen, das Aufnahme-tutorial auf der PyAudio website für die Aufnahme einer festen Länge der Aufnahme, aber ich Frage mich, wie ich das gleiche tun könnte mit einem nicht-festen Aufnahme? Bascially, ich will buttons erstellen, um
Nicht-Blockierung von UDP-Client-Erhalten-Thread-Safe Call
1 Antworten
Bin ich auf der Suche nach einer Lösung für dieses problem, für das Alter. Ich habe versucht, viele Dinge, einschließlich BeginReceive(), aber alles ohne Erfolg. Es muss ein Weg, um dies zu tun, stellen Sie ein UDP-Client
Wie man nicht-blockierend/real-time-Verhalten von Python-logging-Modul? (Ausgabe PyQt QTextBrowser)
3 Antworten
Beschreibung: ich habe geschrieben ein benutzerdefiniertes Protokoll-handler für die capturing-Protokoll-Ereignisse und schreiben Sie einen QTextBrowser Objekt (Arbeits-Beispielcode unten). Problem: Drücken Sie die Taste ruft someProcess(). Dies schreibt zwei strings an die logger Objekt. Allerdings werden die strings
Was ist der Unterschied zwischen blockierenden und nicht-blockierenden Lesen?
4 Antworten
Hinzufügen, um die oben genannte Frage das Konzept einer wait/no wait-Indikator als einen parameter auf einen ReadMessage-Funktion in einer TCP/IP-oder UDP-Umgebung. Dritte Funktion Beschreibung heißt es: Diese Funktion dient zum Lesen einer Nachricht aus einer Warteschlange, welche
Non-blocking thread läuft, dass ein externer Prozess
2 Antworten
Habe ich einen Java-GUI-Anwendung, die Funktionen als wrapper für viele low-level-externe Prozesse. Das Dienstprogramm funktioniert, wie es ist, aber ist in einer verzweifelten Notwendigkeit einer großen Verbesserung. Möchte ich meine externen Prozess laufen, in einer nicht blockierenden
Nicht blockierenden und asynchronen fifo/named pipe in der shell/Dateisystem?
1 Antworten
Gibt es eine Möglichkeit zu schaffen, nicht blockierend/asynchron named pipe oder etwas ähnliches in der Schale? So, die Programme könnten Zeilen, diese Zeilen bleiben im ram, und wenn einige Programm Lesen konnte, ein paar Zeilen aus der
Atomic Instruction
5 Antworten
Was meinst du mit Atomaren Anweisungen? Wie funktioniert das folgende Atomic? TestAndSet int TestAndSet(int *x){ register int temp = *x; *x = 1; return temp; } Aus der software-Perspektive, wenn man Sie nicht verwenden möchten, non-blocking synchronization
Erstellen von nicht-blockierenden socket in python
2 Antworten
Ich versuche zu verstehen, wie nicht-blockierende sockets zu arbeiten ,also schrieb ich dieses einfache server in python . import socket s=socket.socket(socket.AF_INET, socket.SOCK_STREAM) s.bind(('127.0.0.1',1000)) s.listen(5) s.setblocking(0) while True: try: conn, addr = s.accept() print ('connection from',addr) data=conn.recv(100) print
Java: Wie zum test auf EOF auf einem InputStream, ohne zu blockieren?
2 Antworten
Möchte ich etwas wie das hier tun: //Implement an interruptible read for(;;) { if (input.available() > 0) buffer.append(input.read()); else if (input.eof()) return buffer; else Thread.sleep(250); } Wenn ich nicht Sorge über das blockieren, ich würde das getan
Kann Verilog-Variablen gegeben werden lokalen Bereich zu einem immer blockieren?
3 Antworten
Ich manchmal es nützlich finden, verwenden Sie blockierende Zuweisungen für "lokale Variablen" innerhalb getaktet blockiert immer. Dies kann helfen, reduzieren auf wiederholte-code. Nicht versehentlich in die gleiche variable in einem anderen immer blockieren (die kann nicht deterministisch
Nicht-blockierende sockets
5 Antworten
Was ist der beste Weg zur Implementierung eines non-blocking-socket in Java? Oder gibt es so etwas? Ich habe ein Programm kommuniziert mit einem server über Steckdose, aber ich will nicht die socket-Aufruf zu sperren bzw. zu Verzögerungen,
Thread unterbrechen, nicht beenden blockierenden Aufruf auf die Eingabe-stream Lesen
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
recv mit MSG_NONBLOCK und MSG_WAITALL
3 Antworten
Möchte ich recv syscall mit nicht blockierende Flaggen MSG_NONBLOCK. Aber mit diesem flag syscall zurückkehren kann, bevor der vollständige Antrag ist zufrieden. So, kann ich hinzufügen flag MSG_WAITALL? Wird es nicht blockierender? oder wie muss ich das
Non-Blocking File-IO in Java
4 Antworten
Möchte ich schreiben auf eine named pipe (bereits erstellt), ohne zu blockieren auf den Leser. Mein reader ist eine Anwendung, die gehen. Wenn der Leser nicht nach unten gehen, ich will, dass die writer Anwendung zu halten,
BSD-Sockets - Wie verwendet nicht-blockierende sockets?
4 Antworten
Ich versuche, verwenden Sie nicht blockierende TCP-sockets. Das problem ist, dass Sie noch zu blockieren. Der code ist unten - server-code - struct sockaddr name; char buf[80]; void set_nonblock(int socket) { int flags; flags = fcntl(socket,F_GETFL,0); assert(flags
Node.js vs Async/await in .net
4 Antworten
Kann sich das jemand erklären/redirect mich, was ist der Unterschied zwischen Node.js's async-Modell(non-blocking thread) vs jede andere Sprache, zum Beispiel in c#die asynchrone Art und Weise der Handhabung der I/O. Dieser sieht zu mir, dass beides das
Einfache, nicht-blockierende Art zu schlafen?
8 Antworten
Googelte ich nach dieser und lese einige threads hier, aber ich habe nicht gefunden, eine einfache Möglichkeit zu haben, eine VB.Net Anwendung Schlaf für eine Weile und immer noch halten die Anwendung reaktionsschnell Weg: Imports System.Net Imports
Nicht Blockierenden recv () - Sockets in C
4 Antworten
Bin ich mit einer Endlosschleife in-buchsen, in denen, wenn es empfängt einige Daten, die er erhalten soll, oder wenn es will, zum senden von Daten, die es sendet. So etwas wie unten angegeben. Ich bin mit auswählen.
SSH-Modul für python
1 Antworten
Ich muss ein job (mit meinem web-server) auf einer remote-Maschine, die dauert etwa 10 Minuten. Habe ich verwendet pxssh - Modul in python für die gleiche, aber es gibt mir "timeout-Fehler"(non-blocking). Nun, ich bin mit paramiko aber
TNonblockingServer, TThreadedServer und TThreadPoolServer, die man am besten passt für meinen Fall?
2 Antworten
Unseren Analyse-server ist in c++ geschrieben. Es ist im Grunde Abfragen zugrunde liegenden storage-engine und gibt eine ziemlich große strukturierte Daten über Sparsamkeit. Eine typische Anfragen dauert etwa 0,05 bis 0,6 Sekunden zu beenden, hängt davon ab,
Python: Nicht blockierenden socket oder Asynchronos I/O
3 Antworten
Ich bin neu in Python und aktuell zu schreiben, ein python-socket laufen, ein Skript, die die Kommunikation mit einem Gerät über TCP/IP (Wetter-station). Das Gerät fungiert als Server-Seite (hören über IP:PORT verbindungen akzeptiert, Empfang-Anfrage, die übertragung von
C# non-blocking-socket-ohne while(true) Schleife
4 Antworten
Ich versuche nur, um einige socket-Programmierung, Verwendung von non-blocking sockets in c#. Die verschiedenen Beispiele, die ich gefunden habe, wie diese, scheint die Verwendung einer while(true) - Schleife, aber diese Vorgehensweise bewirkt, dass die cpu zu burst
Ermöglichen non-blocking socket
2 Antworten
Ich habe einen server geschrieben in C/C++. Ich habe die wrapper für die Verbindung wie folgt: //START WRAPPER void Server::init_address(int port) { memset(&(this->serv_addr), 0, sizeof(this->serv_addr)); this->serv_addr.sin_family = AF_INET; this->serv_addr.sin_port = htons(port); this->serv_addr.sin_addr.s_addr = htonl(INADDR_ANY); } int Server::w_socket()
Wie readline-unendlich in Node.js
1 Antworten
while(1){ rl.question("Command: ",function(answer){ console.log(answer); }) } Habe gerade versucht diesen code, aber stattdessen Holen Sie sich input eins nach dem anderen, es blinkt die "Command:" - Zeile. Ich weiß node.js ist non-blocking, aber ich weiß nicht, wie
Einfache, thread-sichere non-blocking-Datei logger-Klasse in c#
3 Antworten
Ich habe eine web-Anwendung, das sich einige Informationen in einer Datei. Ich bin auf der Suche nach eine einfache, thread-sichere non-blocking-Datei logger-Klasse in c#. Ich habe wenig Erfahrung mit threading. Ich bekannt, es gibt große logging Komponenten
async / wait non-blocking warten in python
1 Antworten
ich die Ausgabe jeden Buchstaben einer Zeichenfolge warten und nach einiger Zeit, einen Schreibmaschinen-Effekt. for char in string: libtcod.console_print(0,3,3,char) time.sleep(50) Aber dieses blockiert den main thread, und das Programm schaltet inaktiv. Kein Zugang mehr, bis es abgeschlossen
SocketCAN kontinuierliche Lesen und schreiben
4 Antworten
Ich Schreibe ein Programm, das kontinuierlich sendet "Hallo" an einen CAN-bus und liest Daten aus dem bus über SocketCAN. Ich will diese beiden Schritte unabhängig zu sein. Das bedeutet, dass selbst wenn es keine Daten auf den
recv mit nicht-blockierenden socket
2 Antworten
Bin ich versucht zu implementieren non-blocking socket recv und das problem ist, dass ich einen Fehler -1, wenn es keine Daten, aber ich erwarte, dass man EAGAIN Fehler. Socket set auf jeden Fall auf non-blocking state, überprüfte
Wie das umzusetzen, non-blocking-socket-server in python
1 Antworten
Eine ähnliche, aber andere Frage: Ich habe einen IRC-client, erzeugt strings. Dieser IRC-client verwendet einen Haken, um eine Methode aufzurufen (somone_said) wenn jemand etwas sagt. Ich möchte sendet diese Zeichenkette über ein socket zu meinem flash-client. Ich
Mit select() für nicht-blockierende sockets eine Verbindung gibt immer 1 zurück
2 Antworten
Diese Frage ist sehr ähnlich (fast identisch)In einer nicht blockierenden socket-Verbindung herzustellen, wählen Sie() gibt immer 1 zurück; jedoch, ich kann nicht scheinen, um herauszufinden, wo mein code ist ins stocken geraten. Ich bin mit non-blocking sockets
Python Wecker
2 Antworten
Habe ich dieses kleine Wecker mit ein wenig Hilfe von meinem Bruder. Ich versuchte es Letzte Nacht, mit der nonBlockingRawInput - und das funktionierte gut, aber mit der nonBlockingRawInput es hat nicht funktioniert. Heute habe ich es
Wie man eine verzögerte non-blocking-Funktion aufrufen
3 Antworten
Möchte ich nennen, die add Funktion eines HashSet mit einiger Verspätung, aber ohne blockieren des aktuellen Threads. Gibt es eine einfache Lösung zu erreichen, so etwas wie dieses: Utils.sleep(1000, myHashSet.add(foo)); //added after 1 second //code here runs
Monitoring-Datei mit inotify
2 Antworten
Ich bin mit inotify überwachen eine lokale Datei, zum Beispiel "/root/temp" mit inotify_add_watch(fd, "/root/temp", mask). Wenn diese Datei gelöscht wird, wird das Programm blockiert read(fd, buf, bufSize) Funktion. Auch wenn ich eine neue erstellen "/root/temp" - Datei,
Wie man eine akzeptierte socket non-blocking in java
5 Antworten
Ich bin der Annahme, dass eine Verbindung von einem client und dann vorbei, verbundenen socket aus einem anderen Objekt, jedoch, dass die Buchse muss nicht-blockierend. Ich bin versucht zu verwenden getChannel().configureBlocking(false) aber das scheint nicht zu funktionieren.
So erstellen Sie eine Java-nicht blockierende InputStream aus einer HttpsURLConnection?
5 Antworten
Grundsätzlich habe ich eine URL, die xml-streams updates aus einem chat-Zimmer auf, wenn neue Nachrichten veröffentlicht werden. Ich würde gerne, dass die URL in einen InputStream und Lesen aus es so lange wie die Verbindung aufrechterhalten wird,
Java NIO: Wie Sie wissen, wenn SocketChannel read() ist komplett mit non-blocking I/O
4 Antworten
Ich bin derzeit mit einer non-blocking SocketChannel (Java 1.6) zu handeln, als ein client zu einem Redis-server. Redis akzeptiert plain-text-Befehle direkt über ein socket, beendet durch CRLF und reagiert-wie ein kurzes Beispiel: SENDEN: 'PING\r\n' RECV: '+PONG\r\n' Redis
Bash-Skript mit nicht-blockierenden Lesen
3 Antworten
Ich möchte, um Daten zu senden, um eine root-Prozess mit einer named pipe. Hier ist das Skript und es funktioniert Super: #!/bin/sh pipe=/tmp/ntp if [[ ! -p $pipe ]]; then mknod -m 666 $pipe p fi while
java-Nicht blockierende HTTP-client
2 Antworten
Habe ich eine hohe Lautstärke java-Anwendung, in der ich zum senden von http-posts auf einen anderen server. Derzeit bin ich mit org.apache.Unterhaus.httpclient Bibliothek: private static void sendData(String data) { HttpClient httpclient = new HttpClient(); StringRequestEntity requestEntity; try
Java-Serialisierung, ObjectInputStream.readObject(), prüfen Sie, ob wird block
4 Antworten
Ich bin mit einem ObjectInputStream zu nennen readObject zum Einlesen von serialisierten Objects. Ich möchte vermeiden, dass diese Methode-block, ich bin auf der Suche nach so etwas wie Inputstream.available(). InputStream.available() wird Ihnen sagen, es sind bytes, die
In einer nicht blockierenden socket-Verbindung herzustellen, wählen Sie() gibt immer 1 zurück
2 Antworten
Habe ich dieses code-segment, das entworfen ist, um eine Verbindung zu einem server über eine socket-Verbindung. Allerdings, wenn es keine Verbindung mit dem server innerhalb einer gewissen Zeit möchte ich es halt versuchen. Ich habe versucht, dies
Python - Wie kann ich diese code asynchron?
5 Antworten
Hier ist etwas code, der veranschaulicht mein problem: def blocking1(): while True: yield 'first blocking function example' def blocking2(): while True: yield 'second blocking function example' for i in blocking1(): print 'this will be shown' for i
Wenn einer nicht blockierenden recv mit MSG_PEEK erfolgreich ist, wird eine nachträgliche recv ohne MSG_PEEK auch gelingen?
5 Antworten
Hier ist eine vereinfachte version der code an dem ich arbeite: void stuff(int fd) { int ret1, ret2; char buffer[32]; ret1 = recv(fd, buffer, 32, MSG_PEEK | MSG_DONTWAIT); /* Error handling -- and EAGAIN handling -- would
Nicht-blockierend / Asynchron-Ausführung in Perl
6 Antworten
Gibt es eine Möglichkeit zu implementieren, nicht blockierend /asynchron-Ausführung (ohne fork()'ing) in Perl? Früher habe ich ein Python-Entwickler, die für viele Jahre... Python hat wirklich große 'Twisted' framework, das so zu machen (mit DEFERREDs. Bei mir lief
Wie setzen Sie den sockel wieder zu blockierenden Modus (nachdem ich es auf nicht blockierenden Modus)?
3 Antworten
Ich dies gelesen haben, bezüglich der Einstellung ein socket auf non-blocking-Modus. http://www.gnu.org/software/libc/manual/html_mono/libc.html#File-Status-Flags Hier ist was ich getan habe: static void setnonblocking(int sock) { int opts; opts = fcntl(sock,F_GETFL); if (opts < 0) { perror("fcntl(F_GETFL)"); exit(EXIT_FAILURE); } opts
Wenn ein nicht-blockierendes send() überträgt nur teilweise Daten, können wir annehmen, dass er zurückkehren würde, EWOULDBLOCK den nächsten Anruf?
2 Antworten
Beiden Fälle sind gut dokumentiert in der man-Seiten für nicht-blockierende sockets: Wenn send() liefert die gleiche Länge wie der transfer-Puffer die gesamte übertragung erfolgreich beendet und der socket werden kann oder nicht in einem Zustand der Rücksendung
Wie zu verwenden QThread richtig in pyqt mit moveToThread()?
2 Antworten
habe ich diesen Artikel gelesen Wie Wirklich, Wirklich Verwenden QThreads; Die Vollständige Erklärung, heißt es statt Unterklasse qthread, und implementieren Sie die run () -, sollte man Sie nutzen moveToThread zu schieben ein QObject auf QThread Beispiel
Wie bekomme ich nicht-blockierenden socket connect()'s?
5 Antworten
Ich habe ein ziemlich einfaches problem hier. Ich brauche für die Kommunikation mit einer Vielzahl von hosts gleichzeitig, aber ich habe nicht wirklich benötigen keine Synchronisierung, da jede Anfrage ist ziemlich autark. Deshalb wählte ich die Arbeit
senden einer non-blocking HTTP-POST-request
6 Antworten
Ich habe zwei Webseiten in php und python. Wenn ein Benutzer sendet eine Anfrage an den server ich brauche php/python, um das senden einer HTTP-POST-Anforderung an einen remote-server. Ich möchte die Antwort an den Benutzer sofort und
Ist O_NONBLOCK gesetzt ist eine Eigenschaft der Datei-Deskriptor oder die zugrunde liegenden Datei?
1 Antworten
Von dem, was ich gelesen habe auf Der Open-Group-website auf fcntlopenreadund schreibenhabe ich den Eindruck, dass ob O_NONBLOCK festgelegt ist, auf einem Datei-Deskriptor, und somit, ob eine nicht-blockierende I/O wird mit dem Deskriptor, sollte zu einer Eigenschaft
- 1
- 2