executors

    1

    1答えて

    私は同時に複数の要求を処理する必要があるHTTPServerを構築しています。 私はこのようになります建て何の主な機能: public static void main(String[] args) throws Exception { HttpServer server = HttpServer.create(new InetSocketAddress(8000), 0);

    1

    4答えて

    Thread-poolを使用する理由の例を説明することができます。 理論的にはExecutorsでスレッドプールの使用について知っています。 私はチュートリアルの数を経ていますが、私たちはスレッドプールを使用すべき理由についていかなる実質的に例を取得していない、それは、スケーラビリティとパフォーマンスの面でnewFixedThreadPoolまたはnewCachedThreadPoolまたはnew

    5

    3答えて

    Executorによって実行される一連のタスク(つまり、Runnable)があります。 各タスクには、続行するために有効な一定の条件が必要です。私は何らかの方法でExecutorをキューの最後に移動し、条件が有効でタスクを実行して終了できるときに実行しようとする方法があるかどうかを知ることに興味があります。 Thread-1テイクキューからタスクとrunキューの最後に条件がまだ有効 作業ではありま

    1

    1答えて

    キューの上部または下部に新しいタスクを追加するかどうかを選択できるようにしたいと思います。それを達成する最も簡単な方法は何ですか?

    3

    1答えて

    私は、ネットワーク上のデータを取得するためのシングル・スレッド・エグゼキュータ・サービスを持っています。 ユーザが検索ボックスに入力するとき、私は可能なネットワークタスクを待ち行列に入れています。私が望むのは、以前のすべてのリクエストを取り消して、すぐに最新のものをエンキューしてすぐに実行することです。 私の現在の方法は、superを呼び出す前にexecute()メソッドとsubmit()メソッド

    3

    2答えて

    にキャンセル(true)を呼びますか?done()メソッドでコードを実行するカスタムクラスMyFutureTask extends FutureTask<Void>があります。 私はsubmit(new MyFutureTask())と呼ぶExecutorServiceを使用します。 送信を呼び出した後に返されるFuture<?>への参照を保持することができますが、キャンセルを呼び出すと、isCa

    1

    2答えて

    私は現在、複数のクライアントが接続するサーバーを作成しています。通信プロトコルは、基本的にサーバーがクライアントにタスクを送信し、クライアントがタスクの実行時に応答することです。クライアントはサーバーに接続したままで、切断しないでください。 現在、私は各クライアントを扱う新しいスレッドを開始しています。 (Java Concurrency in practiceからソース) public clas

    5

    4答えて

    私は、タスクを実行するためにsingleThreadExecutorを持っています。つまり、並行して実行されないタスクが1つずつ順番に実行されます。以下のようなものだ 私が実行可能にしていこの MyRunnable implements Runnable { @Override public void run() { try { Thread.sleep(30000);

    7

    3答えて

    プロデューサとコンシューマのパターンを理解することは、プロデューサとコンシューマの間で共有されるキューを使用して実装できることです。プロデューサは共有キューに作業を送信し、コンシューマはキューを取得して処理します。また、プロデューサが直接コンシューマに提出することで実装することもできます(コンシューマのエグゼキュータサービスに直接提出するプロデューサスレッド)。 ここでは、スレッドプールの一般的な

    3

    1答えて

    私のアプリケーションでスレッドプールを使用しています。私はTreadPoolExecutorをサブクラス化し、メソッドbeforeExecute、afterExecuteをオーバーライドし、統計的な目的で終了しました。 私自身のThreadFactoryを実装し、newThreadメソッドをオーバーライドしました。 私は、スレッドプールラッパークラスが「呼び出し可能な」タスクを十数作成し、invo