equal
deleted
inserted
replaced
15 testPipeWriteRead |
15 testPipeWriteRead |
16 | makeReader makeWriter count threads ok blocker | |
16 | makeReader makeWriter count threads ok blocker | |
17 |
17 |
18 count := 1000. |
18 count := 1000. |
19 threads := 200. |
19 threads := 200. |
|
20 "/ There's limit to 50 open files in BCC5.5 libc, sigh. |
|
21 OperatingSystem isMSWINDOWSlike ifTrue:[ |
|
22 threads := 20. |
|
23 ]. |
20 ok := true. |
24 ok := true. |
21 blocker := Semaphore new: threads negated + 1. |
25 blocker := Semaphore new: threads negated + 1. |
22 makeReader := [ :stream | |
26 makeReader := [ :stream | |
23 [ |
27 [ |
24 | c | |
28 | c | |