..

yielding · yielding · commit 313af8684b94 · 2023-04-03T19:29:49.000+09:00
diff --git a/cpp.boost/bounded.buffer/CMakeLists.txt b/cpp.boost/bounded.buffer/CMakeLists.txt
@@ -1,4 +1,4 @@
-cmake_minimum_required (VERSION 3.22.2)
+cmake_minimum_required (VERSION 3.26)
 
 project (bounded.buffer)
 
diff --git a/cpp.fp/count.lines/CMakeLists.txt b/cpp.fp/count.lines/CMakeLists.txt
@@ -0,0 +1,25 @@
+cmake_minimum_required(VERSION 3.26)
+
+project(count.lines)
+
+set (CMAKE_CXX_STANDARD 23)
+set (CMAKE_EXPORT_COMPILE_COMMANDS ON)
+
+set (SOURCES
+  count.lines.cpp
+)
+
+include_directories (
+  /usr/local/include 
+  /opt/homebrew/include
+  ${CMAKE_CURRENT_SOURCE_DIR}
+)
+
+link_directories (
+  /usr/local/lib 
+  /opt/homebrew/lib
+)
+
+add_executable(count.lines 
+  ${SOURCES}
+)
diff --git a/cpp.fp/count.lines/count.lines.cpp b/cpp.fp/count.lines/count.lines.cpp
@@ -0,0 +1,93 @@
+#include <iostream>
+#include <vector>
+#include <string>
+#include <fstream>
+
+#include <range/v3/view/transform.hpp>
+#include <range/v3/range/conversion.hpp>
+
+namespace view = ranges::views;
+using namespace ranges;
+using namespace std;
+
+auto count_file_lines(ifstream in) -> int;
+auto count_lines(const string& filename) -> int;
+auto open_file(string const& filename) -> ifstream;
+
+auto original_count_lines_in_files(const vector<string>& files) -> vector<int> 
+{ 
+  vector<int> results(files.size());
+
+  transform(files.cbegin(), files.cend(), 
+            results.begin(), 
+            count_lines);
+
+  return results;
+}
+
+auto count_file_lines(ifstream in) -> int
+{ 
+  return count(
+    istreambuf_iterator<char>(in), 
+    istreambuf_iterator<char>(), 
+    '\n'
+  );
+}
+
+auto count_lines(const string& filename) -> int
+{ 
+  ifstream in(filename);
+
+  if (!in.good())
+    return 0;
+
+  return count(
+    istreambuf_iterator<char>(in), 
+    istreambuf_iterator<char>(), 
+    '\n'
+  );
+}
+
+auto open_file(string const& filename) -> ifstream 
+{
+  try
+  {
+    return ifstream{filename};
+  }
+  catch(...)
+  {}
+
+  return ifstream{};
+}
+
+//
+// What a monad!
+//
+auto count_lines_in_files(vector<string>& files) -> vector<int> 
+{ 
+  return files 
+    | view::transform(count_lines) 
+    | to<vector>();
+}
+
+auto count_lines_in_files2(vector<string>& files) -> vector<int> 
+{ 
+  return files 
+    | view::transform(open_file) 
+    | view::transform(count_file_lines)
+    | to<vector>();
+}
+
+int main(int argc, char* argv[])
+{
+  vector<string> files{
+    "/Users/yielding/code/big.read.write.cpp",
+    "/Users/yielding/code/big.read.write.cpp"
+  };
+
+  auto res = count_lines_in_files2(files);
+  for (auto r : res)
+    cout << r << " ";
+
+  return 0;
+}
diff --git a/cs/threadpool/producer.consumer/blocking.collection.cs b/cs/threadpool/producer.consumer/blocking.collection.cs
@@ -49,6 +49,8 @@ static void NonBlockingConsumer(BlockingCollection<int> bc, CancellationToken ct
         break;
       }
 
+      // REAMRK
+      // : consumers work here!
       // Slow down consumer just a little to cause
       // collection to fill up faster, and lead to "AddBlocked"
       Thread.SpinWait(500000);

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-cmake_minimum_required (VERSION 3.22.2)`
	`1`	`+cmake_minimum_required (VERSION 3.26)`
`2`	`2`
`3`	`3`	`project (bounded.buffer)`
`4`	`4`
Original file line number	Diff line number	Diff line change
`@@ -49,6 +49,8 @@ static void NonBlockingConsumer(BlockingCollection<int> bc, CancellationToken ct`
`49`	`49`	`break;`
`50`	`50`	`}`
`51`	`51`
	`52`	`+ // REAMRK`
	`53`	`+ // : consumers work here!`
`52`	`54`	`// Slow down consumer just a little to cause`
`53`	`55`	`// collection to fill up faster, and lead to "AddBlocked"`
`54`	`56`	`Thread.SpinWait(500000);`