常連

### 知りたいこと
今日マルチスレッドについて触れたばかりです。
全体的に並列処理についての理解がありません。


OpenMPを使用してマルチスレッド化を試みているのですが、

並列計算をする際にCPUに記載されたコア数/スレッド数を超えたスレッド数を設定できます。
それによって計算速度も上昇します。
これが一体何を意味するのか、ということが知りたいです。

cpuはi7 9700F,8コア8スレッドです。
[https://ark.intel.com/content/www/jp/ja/ark/products/193738/intel-core-i7-9700f-processor-12m-cache-up-to-4-70-ghz.html](https://ark.intel.com/content/www/jp/ja/ark/products/193738/intel-core-i7-9700f-processor-12m-cache-up-to-4-70-ghz.html)

### 実装内容
並列計算は以下のように書いていて
```C++
#include <omp.h> // OpenMP
~~~~省略~~~~
int N = 1000000;
#pragma omp parallel for num_threads(num) // numの値がスレッド数にあたる
	for(int i = 0; i < N; i++)process(); // 100万の処理
```
process()は
```C++
	int num = 0;
	for(int i = 0; i < 10000; ++i) // 内部で1万ループする
	{
		++num;
	}
```

process内1個の計算時間は0.02msくらい

### 計測結果

スレッド数とその速度を表にまとめた図が下です。
![イメージ説明](349908fb44cfc0d2730f12d5802edcd3.png)

1~8スレッドまではCPUのコアが利用できるのでわかります。
16~512までCPUコア数、スレッド数超えた状態で指定すると、指定スレッド数が倍々で上がるにつれ計算効率が最大3%くらい上昇しています。
なぜ上昇するのかもよくわかってないんですが、
一番知りたいのは、CPUに記載されてるスレッド数を越して設定して大丈夫なのか？という点です。
どなたかご教授いただけますと幸いです。

マルチスレッドでCPUのコア/スレッド数を超えたスレッドを指定するということはどういうこと？

### 前提・実現したいこと

以前も似たようなご質問をさせていただきましたが、再度質問させていただきます。
[以前の質問](https://teratail.com/questions/254257)

C#でUSB接続でシリアル通信を行うWindowsアプリを作成しています。
同時に複数のデータが来た場合に対応するために、マルチスレッドに変更したいと思っております。
が、恥ずかしながらマルチスレッドの実装を行ったことがなく、ググってもイマイチだったため、
皆さまのお力を借りたいと思いました。
現状は、データが2回来て正常なデータとするため、同時に来た場合にさばけない状態となっています。
（先勝ちな状態です。）

データの一連の流れは、下記になります。
①データ受信[1回目]
②データ受信[2回目] ← ここでデータ確定
③受信データをAPI経由でDBへ格納
④戻り値を受信元へ送信

### 該当のソースコード

```C#
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.IO;
using System.IO.Compression;
using System.IO.Ports;
using System.Net.Http;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Xml.Linq;

namespace App
{
	public partial class Form : Form
	{
		private SerialPort serialPort;

		// APIパス
		private const string API_PATH = @"http://XXXXX";

		private int			iRetry = 1;
		private int			iSeq = 0;
		private string		sBefData = string.Empty;
		private string		sData = string.Empty;
		private string		sVal1 = string.Empty;
		private string[]	sReturnVal = new string[2];
		private bool		bFirst = true;

		readonly string sPath = AppDomain.CurrentDomain.BaseDirectory;
		private string sFilePathBefore;
		string sLogFolder = "LogFile";
		private bool bSuccess = false;

		public Form()
		{
			InitializeComponent();
		}

		/// <summary>
		/// フォームロード時イベント
		/// </summary>
		/// <param name="sender"></param>
		/// <param name="e"></param>
		private void Form_Load(object sender, EventArgs e)
		{
			string[] ports = SerialPort.GetPortNames();
			foreach (string port in ports)
			{
				this.cmbSerials.Items.Add(port);
			}
			if (0 < this.cmbSerials.Items.Count)
			{
				this.cmbSerials.SelectedIndex = 0;
			}
		}

		/// <summary>
		/// 接続ボタン押下時イベント
		/// </summary>
		/// <param name="sender"></param>
		/// <param name="e"></param>
		private void btnConnect_clicked(object sender, EventArgs e)
		{
			if (this.cmbSerials.SelectedItem != null && this.serialPort == null)
			{
				// COMポートをOPEN
				serialPort = new SerialPort();
				serialPort.DataReceived += new SerialDataReceivedEventHandler(SerialPort1_DataReceived);
				serialPort.PortName  = this.cmbSerials.SelectedItem.ToString();
				serialPort.BaudRate  = 19200;
				serialPort.DataBits  = 8;
				serialPort.Parity    = Parity.None;
				serialPort.StopBits  = StopBits.One;
				serialPort.Encoding  = Encoding.UTF8;

				try
				{
					serialPort.Open();
				}
				catch (Exception ex)
				{
				}
			}
		}

		/// <summary>
		/// データ受信時イベント
		/// </summary>
		/// <param name="sender"></param>
		/// <param name="e"></param>
		private void SerialPort1_DataReceived(object sender, SerialDataReceivedEventArgs e)
		{
			if (serialPort != null && serialPort.IsOpen)
			{
				try
				{
					// 受信データを読み込む
					SerialPort sp = (SerialPort)sender;
					string sChildData = sp.ReadExisting();

					if (sChildData.Length == 2 && bFisrst)
					{
						sVal1 = sChildData;
					}
					else
					{
						sData = sChildData;
						if (bFirst) {
							return;
						}
					}

					if (!string.IsNullOrEmpty(sData) && !string.IsNullOrEmpty(sVal1))
					{
						if (0 < sData.Length) {
							if (string.IsNullOrEmpty(sBefData) || sBefData != sData)
							{
								var parameters = new Dictionary<string, string>()
								{
									// APIへ渡すデータセット
								};
								var content = new FormUrlEncodedContent(parameters);

								try {
									sReturnVal = GetResponseAPI(API_PATH, content);
									sBefData = sData;
									bSuccess = true;
								} catch {
									bSuccess = false;
								}

								if (bSuccess)
								{
									if (0 < sReturnVal.Length)
									{
										try
										{
											// 送信元へデータ送信
										}
										catch (Exception ex)
										{
										}
									}
									else
									{
										this.iRetry = 1;
									}
								}
								sData = string.Empty;
								sVal1 = string.Empty;
								sReturnVal = new string[]{ };
							}
						}
					}
				}
				catch (Exception ex)
				{
				}
			}
		}

		/// <summary>
		/// 終了ボタン押下時イベント
		/// </summary>
		/// <param name="sender"></param>
		/// <param name="e"></param>
		private void btnFinish_clicked(object sender, EventArgs e)
		{
			if (serialPort != null && serialPort.IsOpen)
			{
				serialPort.Close();
				serialPort = null;
			}
		}

		/// <summary>
		/// APIをたたいてレスポンスを取得
		/// </summary>
		private string[] GetResponseAPI(string sApiUrl, FormUrlEncodedContent sContent)
		{
			string[] sVal = new string[2];
			var task = Task.Run(() => {
				return HttpPost(sApiUrl, sContent);
			});
			string response = task.Result;
			JArray data = (JArray)JsonConvert.DeserializeObject(response);
			foreach (JObject obj in data)
			{
				JValue did = (JValue)obj["device_id"];
				JValue val = (JValue)obj["return_data"];
				sVal[0] = (string)did.Value;
				sVal[1] = (string)val.Value;
			}

			return sVal;
		}

		/// <summary>
		/// APIをPOSTする
		/// </summary>
		/// <param name="sUrl">APIのURL</param>
		/// <param name="fContent">引数をエンコードしたもの</param>
		/// <returns></returns>
		async public Task<string> HttpPost(string sUrl, FormUrlEncodedContent fContent)
		{
			var client = new HttpClient();
			var response = await client.PostAsync(sUrl, fContent);
			return await response.Content.ReadAsStringAsync();
		}
	}
}

```

### 補足情報（FW/ツールのバージョンなど）

Windows 10
Visual Studio 2017
c#／Windows Form／.Net Framewrok 4.7.1

シリアル通信でマルチスレッド化（同時受信データを処理したい）

C言語でのマルチスレッドでのログファイル出力したいと考えています。

以下の方法にて、試みてみましたが、ログを確認するとマルチスレッドの為か、グチャグチャになってしまいます。
排他制御等が必要なのでしょうか？
詳しい方、教示願います。

・7/12 追記
返答遅くなりすいません。

ファイルがグチャグチャというのは、其々のタスクから出力した文字列が混ざったような出力結果ということです。
正確にはマルチスレッドというより、マルチタスクです。
[プラットフォーム]　vxWorks




```ここに言語を入力
#include <stdio.h>
#include <sys/types.h>

FILE *fp;
char filename[] = "sample.log";

void log(void) {
    fprintf(fp, "%s : tid => %d\n", __func__, gettid());
    
　　/*7/12補足漏れ追記 */
    fflush(fp);
}

int main(void) {
    /* ファイルオープン */
    if ((fp = fopen(filename, "a+")) == NULL) {
        fprintf(stderr, "ファイルのオープンに失敗しました．\n");
        return EXIT_FAILURE;
    }

    /*途中簡略 複数スレッド起動して、各スレッドから上記log関数をコールする*/

    /* ファイルクローズ */
    fclose(fp);
}
```

C言語でマルチスレッドでのファイル出力

以下のようなエラーが度々でてしまうのですが原因はなんなのでしょうか？
```Error
undefined reference t'
/lib/x86_64-linux-gnu/libpthread.so.0: error adding symbols: DSO missing from command lie
collect2: error: ld returned 1 exit status
```

ちなみにコンパイルだけであれば-lpthreadの部分を
-pthreadに変更するとなぜか通ります。
自分の解釈では-lpthread というように記述することによりincludeをした際に 
/usr/lib/-----
を探しにいくことでなにか原因がありErrorがおこっているのか？と思いました。

c++プログラムのエラーについて

### 問題点

C言語の標準ライブラリであるはずのthreads.hがインクルードできません。解決方法をご教授願いたいです。

### 環境
OS : windows10
コンパイラ : gcc version 7.5.0 (Ubuntu 7.5.0-3ubuntu1~18.04)

他に補足で必要な情報があればコメントください。
### 発生している問題・エラーメッセージ

```
gw.c:34:10: fatal error: threads.h: No such file or directory
 #include <threads.h>
          ^~~~~~~~~~~
compilation terminated.
```

### 試したこと
MinGWのincludeフォルダの中にthread.hが存在しませんでした。なのでこのようなエラーが出ているのかと思われますが、ここからどのようにすればよいかわかりません。



C言語でthreads.hがインクルードできません

### 前提・実現したいこと

5つの関数（メインを含めると6つ）を並列で行いたいです。
CPU情報を調べてみたところ4個のコア、4個のロジカルプロセッサと記載されていて、threadで実装しようとするとスレッド数が足りないように思います。
調べたところmultiprocessingとjoblibというモジュールではスレッドではなくコアで並列処理を行うとなっていたのですが、threadとmultiprocessingかjoblibを同時に行っても問題ないでしょうか？

### 発生している問題・エラーメッセージ

```
エラーメッセージ
```

### 該当のソースコード

```python
from threading import Thread
from multiprocessing import Pool

def func_1():
    while True:
        ・・・   # とある処理

def func_2():
    while True:
        ・・・   # とある処理

def func_3():
    while True:
        ・・・   # とある処理

def func_4():
    while True:
        ・・・   # とある処理

def func_5():
    while True:
        ・・・   # とある処理

if name == "__main__":
   Thread(target=func_1).start()
   Thread(target=func_2).start()
   Thread(target=func_3).start()

   pool = Pool(2)
   pool.apply_async(func_4)
   pool.apply_async(func_5)

   while True:
       time.sleep(60)
```

### 試したこと

ここに問題に対して試したことを記載してください。

### 補足情報（FW/ツールのバージョンなど）

ここにより詳細な情報を記載してください。

pythonでの並列処理でスレッド数が足りない

anaconda promptからpython aaa.pyで直接動かしてます
aaa.pyは一度起動すると結構時間がかかるので　途中で停止させたいとこがあります
しかしマルチスレッドだと　ctrl＋ｃでは停止させれません　
調べても　コード内でスレッドを停止させる物しかでてきません　すべてのスレッドを手動で一度に中断したいです

python でマルチスレッドのプログラムを途中で停止する方法はりませんか？
わかる人教えてください

python マルチスレッドの中断方法

タグにマルチスレッドを設定しましたが実際はマルチプロセスです.
ファイルにマルチプロセスからアクセスしたいのですが, 各プロセスで競合がおこってしまうとファイルがこわれてしまう可能性があると思います。

最適な設計としてstatic グローバル変数として鍵を定義し, 排他制御をするのが正しいのかと思ったのですが, これは正しいのでしょうか？
なにか別に簡単な方法があれば教えていただきたいです。

PS

os はunix系です