executor

0熱

1答えて

私はスケジューラと並行して多くのスケジュールされたタスクを実行しようとしますが、1つだけ起動します。 spring-scheduler.xmlの私のbean設定 <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http

0熱

2答えて

ExecutorService - クラスごとに1つのメソッドに対して新しいインスタンスを作成する

すべてのメソッド呼び出しで新しいExecutorServiceを作成するか、クラスごとに1つずつ使う必要がありますか？パフォーマンスの面で好ましい選択肢はどれですか？あなたの最初のコードで public class NotificationService { public void sendNotification(User recipient) { ExecutorSe

2熱

2答えて

TomEEのマネージエグゼキュータサービス

TomEE + 7.0.2にJava EE 7 REST APIをホストする48個のCPUを持つサーバーがあります。一部のAPIでは、並列化されたアルゴリズムを実行するときに、できるだけ多くのCPUを使用する必要があります。並列化された部分は、データベースや他のリソースを必要とせず、共用double [] []マトリックス内で幾分か重く持ち上げるだけです。私は通常、EJBコンテキストで作業し

0熱

1答えて

GitlabのKubernetes Executor用kubernetes APIに接続

https://docs.gitlab.com/runner/executors/kubernetes.html#connecting-to-the-kubernetes-apiによると、私は現在のGitlabランナーから別のK8sクラスターに接続できますが、あなたは何をしているのか、どこでこれらのオプションを指定する必要があります。 EDIT：最後にconfig.tomlでこれらのオプションを指

2熱

1答えて

ScheduledThreadPoolExecutorによるスケジューリングをどうやって保証することができますか？

私は、ScheduledThreadPoolExecutorのこの問題に取り組んでいる初心者のプログラマーです。私はいくつかのグーグルで、afterExecuteメソッドを使用してRunnable（）から例外を処理する方法を知る必要がありました。今それはこれまでに沸く。 ScheduledThreadPoolExecutorのscheduleAtFixedRate（）メソッドがエラーを解除し、ス

0熱

1答えて

sparkが単一のエグゼキュータ上で複数のパーティションを持つジョブを実行しています

Mesosクラスタで実行されているSpark 2.1.1ジョブがあります。 Spark UIは32人の実行中のエグゼキュータを表示し、RDD.getNumPartitionsは28個のパーティションを表示しています。しかし、1人（ランダム）のエグゼキュータだけが仕事をしており、他のすべては完了しているとマークされています。 executorコード（stdout）にdebugステートメントを追加し

0熱

2答えて

SparkでExecutor Startupのフックがありますか？

基本的には、共有メモリからデータを読み込むために、同じノード/エグゼキュータ上で複数のタスクを実行します。そのためには、タスクを開始する前にデータをメモリにロードする初期化関数が必要です。もしSparkがExecutorの起動のためのフックを提供するならば、この初期化コードをそのコールバック関数に入れて、この起動が完了した後にタスクが実行されるようにすることができます。私の質問は、スパークはその

3熱

1答えて

"Runnable :: run" - これはExecutorインスタンスをどのように作成していますか？

私は次の行がテストキュータのメンバ変数のインスタンスを作成するために使用されたプロジェクトに取り組んでいます： private Executor executor = Runnable::run; コードが実行され、コンパイルが、私はRunnable::runはのインスタンスを作成する方法を理解していませんExecutorはどちらも異なるインターフェイスです。誰でも説明できますか？特に： Run

0熱

1答えて

複数のスレッドプール、つまりそれぞれが単一のスレッドを持つ複数のエグゼキュータを作成する方法

現在、複数のスレッドプールを作成する必要があります。各スレッドプールは単一スレッドのスレッドプールです。条件に基づいて各スレッドプールにタスクを割り当てます。だから私はスレッドプールの追跡を維持する必要があります。どうすればいいですか？スレッドプールの配列を作成できますか？ ExecutorService executor = Executors.newSingleThreadExecuto

2熱

3答えて

ExecutorService：スレッドフロー規則の改善

ExecutorServiceスレッドのフロー規則に基づいて質問があります。 executonに複数のスレッドを追加したい場合は、スレッドが終了するまで待つことをお勧めします。実行中。。これまでのところ、私はCountDownLatch（）を使ってこれを行う方法を知っています。 1は、（.await後に追加のスレッドを追加することはできません、 public class Example{ p