Add check for toolsetVersion

Author: Cascades

clcache/__main__.py

@@ -71,6 +71,10 @@
 NMPWAIT_WAIT_FOREVER = wintypes.DWORD(0xFFFFFFFF)
 ERROR_PIPE_BUSY = 231
 
+# Toolset version 140
+# https://devblogs.microsoft.com/cppblog/side-by-side-minor-version-msvc-toolsets-in-visual-studio-2017/
+TOOLSET_VERSION_140 = 140
+
 # ManifestEntry: an entry in a manifest file
 # `includeFiles`: list of paths to include files, which this source file uses
 # `includesContentsHash`: hash of the contents of the includeFiles
@@ -1730,6 +1734,35 @@ def filterSourceFiles(cmdLine: List[str], sourceFiles: List[Tuple[str, str]]) ->
         if not (arg in setOfSources or arg.startswith(skippedArgs))
     )
 
+
+def findCompilerVersion(compiler: str) -> int:
+    compilerInfo = subprocess.Popen([compiler],
+                                    stdout=subprocess.PIPE,
+                                    stderr=subprocess.STDOUT)
+    compilerVersionLine = compilerInfo.communicate()[0].decode('utf-8').splitlines()[0]
+    compilerVersion = compilerVersionLine[compilerVersionLine.find("Version ") + 8:
+                                          compilerVersionLine.find(" for")]
+    return int(compilerVersion[:2] + compilerVersion[3:5])
+
+
+def findToolsetVersion(compilerVersion: int) -> int:
+    versionMap = {1400: 80,
+                  1500: 90,
+                  1600: 100,
+                  1700: 110,
+                  1800: 120,
+                  1900: 140}
+
+    if compilerVersion in versionMap:
+        return versionMap[compilerVersion]
+    elif 1910 <= compilerVersion < 1920:
+        return 141
+    elif 1920 <= compilerVersion < 1930:
+        return 142
+    else:
+        raise LogicException('Bad cl.exe version: {}'.format(compilerVersion))
+
+
 def scheduleJobs(cache: Any, compiler: str, cmdLine: List[str], environment: Any,
                  sourceFiles: List[Tuple[str, str]], objectFiles: List[str]) -> int:
     # Filter out all source files from the command line to form baseCmdLine
@@ -1740,7 +1773,8 @@ def scheduleJobs(cache: Any, compiler: str, cmdLine: List[str], environment: Any
 
     def poolExecutor(*args, **kwargs) -> concurrent.futures.Executor:
         if isTrackerEnabled():
-            return concurrent.futures.ProcessPoolExecutor(*args, **kwargs)
+            if findToolsetVersion(findCompilerVersion(compiler)) < TOOLSET_VERSION_140:
+                return concurrent.futures.ProcessPoolExecutor(*args, **kwargs)
         return concurrent.futures.ThreadPoolExecutor(*args, **kwargs)
 
     with poolExecutor(max_workers=min(jobCount(cmdLine), len(objectFiles))) as executor: