The following will occasionally return false:

open System
open System.Linq
open System.Threading

type pseq<'T> = ParallelQuery<'T>

let inline toP (s : seq<'T>) = 
    match s with
    | null -> nullArg "s"
    | :? pseq<'T> as p ->  p
    | _ -> s.AsParallel()    

let exists2 (f : 'T -> 'U -> bool) s1 s2 = 
    ParallelEnumerable.Any(ParallelEnumerable.Zip(toP(s1), toP(s2),Func<_,_,_>(f)), Func<_,_>(id))

let funcInt x y = (x+y)%3=0 
let Intexists2Seq1 =  seq [1;3;7]
let Intexists2Seq2 = seq [1;6;3]

exists2 funcInt Intexists2Seq1 Intexists2Seq2

Hi all

For some reason no Travis or AppVeyor CI builds are enabled on this repo - could we enable those? It should just be a matter of adding the .travis.yml and appveyor.yml files and registering the repos with the services.

cheers
don

I'm still using VS 2015, targeting 4.6.2, which can't change anytime soon.

Upgrading from 1.0.2 to 1.1.0 results in warning MSB3277, "Found conflicts between different versions of the same dependent assembly...". I guess I'm stuck on 1.0.2 for now?

The README states that one should do nuget\nuget.exe push bin\<the-nuget-package> API-KEY. But as we switched to Paket we need to adjust that.

According to nuget.org, this package is at version 1.0.2, however version 1.0.1 was published later, and is more reflective of the current master branch, in particular Profile7 support.

Could a new package version be released to prevent future confusion.

http://fsprojects.github.io/FSharp.Collections.ParallelSeq/ doesn't work.

Description

ParallelSeq does not have a 'cache' function, analogous to Seq.cache

Expected behavior

Ideally, computed values from the evaluations of parallel sequences would be able to be both cached and forwarded such that multiple later parallel sequences can begin processing those values immediately, without recomputing them and without needing to evaluate the entire source sequence

Actual behavior

Creating an intermediate pseq, then creating two pseq's from that one and enumerating them, causes the first sequence to be evaluated twice. There is currently no way to simultaneously evaluate a source pseq only once and 'stay within the pseq monad'

let intermediate = PSeq.init 10 (fun s -> 
    let ini = sprintf "Initial run: %i" s
    printfn "%s" ini
    ini
) 
intermediate |> PSeq.iter (printfn "Result 1: %s")
intermediate |> PSeq.iter (printfn "Result 2: %s")

Known workarounds

Parallel sequences can be reified to lists, then those lists can be enumerated later on in parallel without recomputing values, but this does not allow the sequences to potentially take advantage of earlier enumerator optimizations (like the conversion of Where and Select to WhereSelect)

A message on nuget:

For some reason version 1.1.1 and 1.1.2 of FSharp.Collections.ParallelSeq don't specify the license like e.g. version 1.1.0 does. Can you please check this?
https://www.nuget.org/packages/FSharp.Collections.ParallelSeq/1.1.0
https://www.nuget.org/packages/FSharp.Collections.ParallelSeq/1.1.1
https://www.nuget.org/packages/FSharp.Collections.ParallelSeq/1.1.2
Thank you!

Regards Tomas Benak

The package authors are not listed correctly. This should be any of

• "F# Community contributors" or
• "F# Incubation Space Contributors (fsprojects)" or
• the maintainers of the package

At the moment it just says this:

Description

The Library appears to not use mutliple cores when using Azure Notebooks

Repro steps

1. Log into Azure Notebooks
2. Clone my Library: http://bit.ly/fspydata
3. Open the Notebook entitled parallelSeq.ipynb
4. Run the parallel example: note that the sequental and the parallel runs are roughly equal
5. Run the processor count example: note the processor count is 8

*running this same code on my local machine returns the expected result: parallel is much faster than serial

Expected behavior

parallel should be faster.

Actual behavior

it is not

Known workarounds

None

Related information

• Operating system: Linux
• Branch (??)
• .NET Runtime, CoreCLR or Mono Version (??)
• Performance information, links to performance testing scripts see above

Not sure if it is a Linux issue or a Azure Notebooks issue?

Description

There is no .NET Core 2.0 version of the NuGet package.

Repro steps

Build a .NET Core 2.0 project that references FSharp.Collections.ParallelSeq.

Expected behavior

No warnings.

Actual behavior

A build warning is logged:

warning NU1701: Package 'FSharp.Collections.ParallelSeq 1.0.2' was restored using '.NETFramework,Version=v4.6.1' instead of the project target framework '.NETCoreApp,Version=v2.0'. This package may not be fully compatible with your project.

Related information

• Windows 7, Linux
• NuGet package 1.0.2
• .NET Core 2.0

The nuget package has a dependency on System.ValueTuple.dll for .NET Framework v4.5, is this possibly a mistake?

Description

While the APIs are extensively documented, this documentation is not available, when consuming the library via the NuGet package.

Repro steps

• Create a new project
• Include the FSharp.Collections.ParallelSeq package
• Try to get any documentation (via mouse over, or intelli sense auto complete)

Expected behavior

Documentation is shown.

Actual behavior

Documentation is not shown.

Known workarounds

Clone the repo and directly include the source files.

Related information

Any OS, any .NET with the 1.1.3 NuGet package.

Description

With package 1.0.2 there is an issue with the execution of FSharp programs. I do get
Method not found: 'Void FSharp.Collections.ParallelSeq.PSeqModule.<method> for all PSeq.methods

This is really strange, I can dissemble the nuget dll and see the functions, the compilation is ok. This used to work and I suspect it is the update of FSharp.Core to 4.4.1.0 that broke the execution. There is no dll loading error in fusion logs.
Also just adding the PSeq source code to my projects did solve the issue but it is ugly.

 TestBinsManagerStatusUpdate : System.MissingMethodException : Method not found: 'Void FSharp.Collections.ParallelSeq.PSeqModule.iter(Microsoft.FSharp.Core.FSharpFunc2<!!0,Microsoft.FSharp.Core.Unit>, System.Collections.Generic.IEnumerable1<!!0>)'. at Apption.MailReader.DataInterfaces.BinsManager.Close() at Apption.MailReader.DataInterfaces.BinsManager.Stop() in F:\code\ParallelMailParser\MailParserLibrary\BinsManager.fs:line 199 at RegressionTest.EndToEndTesting.TestBinsManagerStatusUpdate() in F:\code\ParallelMailParser\RegressionTest\UnitTest1.cs:line 638

Related information

• Operating system: Win 10
• .NET Runtime, CoreCLR or Mono Version: .NET 4.6