stdthread

3熱

1答えて

std :: futureの結果をstd :: packaged_taskから取得するのは安全ですか？

std::packaged_taskからstd::futureを作成することは安全ですか？別のスレッドで実行されますが、必ずしもその結果を取得するとは限りませんか？ #include <future> #include <thread> class Result { Result() {} ~Result() {} }; void foo() { std:

0熱

2答えて

std :: thread throw "リソースのデッドロックが発生する"

私はオブジェクトのリストを持っています。各オブジェクトには、 "update"関数で計算されるメンバ変数があります。私はオブジェクトを並列に更新したい、つまり、オブジェクトを更新するためのスレッドを作成したい。これは妥当なことですか？これが良い考えではない理由は何ですか？以下は、私が記述したことを試みるプログラムです。これは完全なプログラムなので、実行することができます（私はVS2015を使用

5熱

1答えて

std :: threadを終了するには？

私は現在、ソケットサーバーからいくつかのイメージをダウンロードする必要があるプログラムを開発しており、ダウンロード作業は長時間実行されます。だから、私はそれを行うために新しいstd::threadを作成します。 std::threadがダウンロードされると、現在のクラスのメンバー関数が呼び出されますが、このクラスはリリースされている可能性があります。だから、私は例外がある。この問題を解決するには

-1熱

1答えて

pysparkに変換された列を追加する

私はデータフレームにロジスティック回帰を実行しています。スパークのロジスティック回帰関数は不可分なものを取り入れません。私はそれを変換しています。私は文字列インデクサ変換器を使用しています。 indexer=StringIndexer(inputCol="classname",outputCol="ClassCategory") この変換列をデータフレームに追加したいと考えています。 df.

0熱

1答えて

Hadoopアーカイブファイル（HAR）ファイルの読み込みに使用するFileInputFormat

コマンドラインユーティリティhadoop archiveを使用してharファイルを作成しました。 mapreduceまたはsparkでHARファイルの内容を読み取るにはどうすればよいですか？ HARファイルを理解できるFileInputFormatはありますか？答えに従ってください...ここでは、他のケースの誰かでシンプルな豚スクリプトが興味を持っている次のとおりです。 A = LOAD 'h

0熱

1答えて

C++でPAPIを使用する方法11 std：thread？

PAPIを使用して、プログラム内のすべてのC++ 11 std::threadスレッドの全体カウンタを取得したいと考えています。 PAPIライブラリでのスレッドのサポートはCで、以下の低レベルの関数を呼び出すことで初期化することができ：int PAPI_thread_init(unsigned long(*handle)(void));ハンドルがある PAPI documentation on

0熱

1答えて

`std :: this_thread :: sleep_for（）`をMPIプロセスで使用できますか？

MPIは私のプログラムを複数のプロセスで実行します。これらのプロセスのうちの1つをしばらくスリープして、最小限のCPUを使用しています。 std::this_thread::sleep_for()は私が望むように見えますが、この文脈ではthreadビットが少し概略的に見えます。これは問題ありませんか？

18熱

1答えて

ベクトル内のスレッドを結合することはできません

ベクトルにスレッドのコレクションを格納し、それらをすべて結合してプログラムを終了します。関係なく、私がコレクションに置くどのように多くの最初のスレッドに参加しないようにしようとしたとき、私は次のエラーが表示されます。ここ system_error: thread::join failed: No such process は私の問題を示していますいくつかの簡単なコードです： #include

0熱

1答えて

std :: threadメンバ関数。このポインタによってクラスフィールドにアクセスする必要がありますか？以下のようなクラスを考えると

： class MyClass { private: vector<std::string> data; void threadWork(std::vector<std::string> *data_ptr) { // some thread work... e.g for(int i=0; i < data_ptr->size(); i++)

3熱

1答えて

unique_lock <recursive_mutex>を別のスレッドに移動する

recursive_mutexを保持しているunique_lockを移動するとどうなるのだろうかと思っていました。具体的には、私はこのコードを見ていた： recursive_mutex g_mutex; #define TRACE(msg) trace(__FUNCTION__, msg) void trace(const char* function, const char* mess