問題タブ [core.async]

多くの Clojure プログラマーが新しい core.async ライブラリに熱狂しているのを見てきました。非常に興味深いように思えますが、Clojure の原則にどのように準拠しているかを理解するのに苦労しているため、次の質問があります。

1. 関数名が示すように、alt!、put!、>! などのように感嘆符が付けられているため、どこでも変更可能な状態を使用します。チャネルから値を入力または取得すると、そのチャネルはその場で変更されます。不変のデータ構造や純粋な関数などを好むという Clojure の哲学に反していませんか? それとも、変更可能なものをまったく回避できない場合にのみ、core.async を使用するように作られていますか?

2. 「go」はマクロ（したがってコード構造を変更する）であり、「<!」を保証するためです。go-block で直接使用する場合、"<!" を使用することはできません。次のように、別の関数内で：

   これが単純さと構成可能性を妨げているように私には思えます。問題にならないのはなぜですか？

3. おそらく、前の 2 つの問題の結果として、core.async を使用する多くのコードで、map/filter/reduce の代わりに loop/recur などの下位レベルの構造が使用されています。一歩後退じゃない？

ポイントがどこにありませんか？

前もって感謝します。

core.async walk through exampleに基づいて、以下の同様のコードを作成し、10 秒のタイムアウトで複数のチャネルを使用して CPU を集中的に使用するジョブを処理しました。ただし、メインスレッドが戻った後、CPU 使用率は約 700% のままです (8 CPU マシン)。Java プロセスをシャットダウンするには、emacs で手動で nrepl-close を実行する必要があります。

(go..) block によって生成されたマクロスレッドを強制終了する適切な方法はありますか? 近づいてみた！それぞれのちゃんですが、うまくいきません。メインスレッドが戻った後、JavaプロセスによってCPU使用率が0に戻ることを確認したい。

デフォルトでは (go..) は、コア数の 2 倍 + 42 スレッドをスレッド プールに使用します。環境変数または sth を設定することで、コードが使用できるスレッドの数または CPU の数を設定する方法はありますか?

Linux マシンでは、taskset を使用して CPU の数を設定できます。 taskset -c 0,1 my_Java_or_Clojure_program(-> (java.lang.Runtime/getRuntime) .availableProcessors)

このブログ投稿で、著者は次のように書いています。

ただし、Grenchman は、OCaml の最大の産業ユーザーの 1 つである Jane Street の Core および Async ライブラリに基づいて構築されています。Async は、他のイベント ドリブン ツールの多くのコールバックの頭痛の種を回避するモナドの擬似同時実行を可能にしますが、かなりモノリシックです。

Core Async の Jane Street Documentation Pageでは、次のように説明されています。

特に、Async はプログラムの同時実行性をより適切に制御し、競合状態の可能性について簡単に判断できると考えています。

私の質問は、Clojure の core.asyncと OCaml の Core Async の間に類似点はありますか? 「コールバックの問題を回避するための偽の並行性」は、Clojure での core.async の適用と非常によく似ているためです。

おそらく、(<! c)外部の go マクロを使用するための可能な解決策は、マクロとそのマクロ展開時間で実行できます。

これは私の例です：

そしてそれをテストするには：

私はネストされたgoでこのソリューションを試しましたが、うまくいきます。しかし、それが正しい道であるかどうかはわかりません

この質問の理由は、この他の質問に関連しています 、@aeuhuea は、「これが単純さと構成可能性を妨げているように思えます。なぜ問題にならないのでしょうか?」とコメントしています。および @cgrand 応答「go マクロ (その局所性) の制限も機能です。ステートフル操作のソース コードの局所性を強制します。」しかし、コードを強制的にローカライズすることは、「完全にする」ことと同じではありませんか?

独自の非同期関数で core.async の機能を拡張することは推奨されますか?

チャネルの非同期性は、コールバックを受け入れるput!およびによって処理されますが、プロトコルは名前空間take!にネストされています。implは近づかないことを意味async.impl.protocolsしますか？この場合、またはそれらを実装しても大丈夫ですか？

たとえば、Netty チャネルまたは Java ソケットを ReadPort および WritePort としてラップできます。

トップレベルのcore.async go ループがあります。少なくともCTRL-Cまたはkillなどで停止するように通知するまで、無期限に実行したい. 現在、次のようにjava.lang.Runtime/addShutdownHookを使用しています。

ここに私の問題があります：

1. REPL を開始する(run)と、バックグラウンド スレッドで開始および実行されます。REPL を終了すると、目的のシャットダウン メッセージが表示されません。

2. ただし、から実行するlein runと、go ループがすぐに終了し、「SHUTDOWN」と表示されます。

どちらも私が欲しいものではありません。

すべての JVM で機能するソリューションが見つかるとは限りません。私は Mac で開発し、Ubuntu にデプロイするので、両方で機能するソリューションを見つけたいと思います。

• Mac JVM: Java バージョン "1.7.0_45" Java(TM) SE ランタイム環境 (ビルド 1.7.0_45-b18) Java HotSpot(TM) 64 ビット サーバー VM (ビルド 24.45-b08、混合モード)

• Ubuntu JVM: Java バージョン "1.7.0_25" OpenJDK ランタイム環境 (IcedTea 2.3.10) (7u25-2.3.10-1ubuntu0.12.04.2) OpenJDK 64 ビット サーバー VM (ビルド 23.7-b01、混合モード)