From 388055a622b1bf01b0e972e244482d38f771c97d Mon Sep 17 00:00:00 2001 From: matthieugomez Date: Mon, 20 Apr 2020 14:09:52 -0400 Subject: [PATCH] Update find.jl --- src/find.jl | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/find.jl b/src/find.jl index 95e11c2..8eb45dc 100755 --- a/src/find.jl +++ b/src/find.jl @@ -24,6 +24,7 @@ function Base.findmax(s, itr, dist::StringDistance = Levenshtein(); min_score = min_score_atomic = Threads.Atomic{typeof(min_score)}(min_score) scores = [0.0 for _ in 1:Threads.nthreads()] is = [0 for _ in 1:Threads.nthreads()] + # need collect since @threads requires a length method Threads.@threads for i in collect(eachindex(itr)) score = compare(s, itr[i], dist; min_score = min_score_atomic[]) score_old = Threads.atomic_max!(min_score_atomic, score) @@ -60,6 +61,7 @@ julia> findall(s, iter, Levenshtein(); min_score = 0.9) """ function Base.findall(s, itr, dist::StringDistance = Levenshtein; min_score = 0.8) out = [Int[] for _ in 1:Threads.nthreads()] + # need collect since @threads requires a length method Threads.@threads for i in collect(eachindex(itr)) score = compare(s, itr[i], dist; min_score = min_score) if score >= min_score