nonblocking

4熱

1答えて

私の元の解決策https://superuser.com/questions/482953/read-non-blocking-from-multiple-fifos-in-parallel?answertab=oldest#tab-topは、ディスク上にデータのコピーを保存します。私は、メモリ内の行をバッファする2番目のバージョンを作成しました。これは動作しますが、起動する前にすべてのFIF

3熱

2答えて

ノンブロッキングFIFO

2つのpythonプロセスの間でfifoを作ることができます。リーダーが入力を処理できない場合、行を削除することはできますか？読者はライター、その後速くreadまたはreadlineしようとした場合には、それをブロックする必要があり、書き込みます。リーダーがライターの書き込み速度より速く動作しない場合、ライターはブロックしないでください。ラインは一度に1ラインを除いてバッファされるべきではなく

0熱

1答えて

Cソケットアトミック非ブロッキングリード

私はedge-triggeredモードでepollを使用し、ノンブロッキングソケット操作を行うTCP/IPサーバーアプリケーションを実装しています。クライアントはepollなしで単純なブロッキング操作を使用しています。「アトミックリード」をサーバー側でどのように実装できるかわかりません。クライアントとサーバーの両方で64Kバッファーを使用しています。「原子読み取り」の意味を説明するには、次の例

1熱

1答えて

ノンブロッキングサーバーApache Thrift Python

1つのPythonモジュールAではいくつかのことをやっています。そのようなことをしている途中で、私は倹約のつながりを作り出しています。問題は、接続が開始された後で、プログラムがネットワークロジックにスタックされてしまうことです。（すなわち、ブロックする）。私が持っているモジュールAでは：ネットワークで stuff = "do some stuff" network.ConnectionMan

0熱

2答えて

Java：Non-Blocking TCP SocketChannelに書き込まれたすべてのバイトが受信者に送信されたかどうかを調べるAPI？

Thisも同様の回答ですが、私が正確に望むものではありません。私は次の2つのことをしたい：すべてのバイトが受信者に送信されているかどうか調べたいのですか？また、ソケットの出力バッファの現在の残り容量を知りたいと思いますが、書き込みを試みることはありませんか？

2熱

1答えて

非ブロッキングルビデータ処理またはメソッドコール

シリアルポートからデータを読み取るルビースクリプトがあります。そのデータは、特定のプロトコルデータグラムを表す生のバイナリ文字列である可能性があります（私は今のところXBee APIを試しています）。このデータは、メソッド呼び出しの長期的に処理しなければならない、のようなもの：日付から：は解析バイナリデータグラム解析ペイロード変換値（すなわちシリアル読みますタイムスタンプ、線形回帰、な

0熱

1答えて

Java 7 ConcurrentHashMapでは、書き込み中にセグメントロックが必要なのはなぜですか？私たちがUnsafeを使って物事を非ブロックにすることができないのはなぜですか？

Java 7 ConcurrentHashMapの内部実装を行っている間に、私は新しいSegmentを設定することに気付きました.OnDered書き込みを行い、比較およびスワップアルゴリズムを使用してノンブロッキング動作をサポートするUnsafeクラスを使用しています。同時HashMapのは、&書き込みを読んで、単一リンクのためのリストの非ブロッキングの代わりのセグメントにロックを取得して、単独リ

2熱

1答えて

アクタのアクタがデータベースから状態を読み取る

データベースからアクタの状態を初期化する必要がある場合は、パターンを尋ねます。私は将来を返すDAOを持っています... [...]そしてノンブロッキングメッセージがノーマルになることは、将来の完全な俳優に送るべきです。しかし、このケースは異なります。初期化が完了する前に俳優のメールボックスからメッセージを受け取ることができません。データベースの未完了を待っている間にアクタースレッドをブロックする唯

0熱

1答えて

非同期DBライブラリはどのように実装されていますか？

一般的に、非同期的にリクエストを処理するリアクティブな非同期コード（play、akka、nettyなど）の周りには誇大宣伝があります。このようにコードを実行している間は、可能な限り非同期ライブラリをブロックして使用しないことをお勧めします。これを正しく理解すれば、リクエストごとにスレッドを作成するのではなく、それらのライブラリ（リクエストのメイン処理、サービス実行プログラム、非同期DBドライバ

0熱

1答えて

Java AtomicInteger getAndIncrement（）とcompareAndSet

getAndIncrementのcurrentがどのように更新されているかを理解しようとしていますが、ここにそのコードがあります。 public final int getAndIncrement() { for (;;) { int current = get(); int next = current + 1; if (compareAndSet(