• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

LearnLib / learnlib / 6805330902

08 Nov 2023 11:40PM UTC coverage: 93.335% (+0.008%) from 93.327%
6805330902

push

github

mtf90
typo

11736 of 12574 relevant lines covered (93.34%)

1.69 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

66.67
/oracles/parallelism/src/main/java/de/learnlib/oracle/parallelism/DynamicParallelOmegaOracle.java
1
/* Copyright (C) 2013-2023 TU Dortmund
2
 * This file is part of LearnLib, http://www.learnlib.de/.
3
 *
4
 * Licensed under the Apache License, Version 2.0 (the "License");
5
 * you may not use this file except in compliance with the License.
6
 * You may obtain a copy of the License at
7
 *
8
 *     http://www.apache.org/licenses/LICENSE-2.0
9
 *
10
 * Unless required by applicable law or agreed to in writing, software
11
 * distributed under the License is distributed on an "AS IS" BASIS,
12
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
 * See the License for the specific language governing permissions and
14
 * limitations under the License.
15
 */
16
package de.learnlib.oracle.parallelism;
17

18
import java.util.Collection;
19
import java.util.concurrent.ExecutorService;
20
import java.util.function.Supplier;
21

22
import de.learnlib.oracle.MembershipOracle;
23
import de.learnlib.oracle.OmegaMembershipOracle;
24
import de.learnlib.query.OmegaQuery;
25
import net.automatalib.word.Word;
26
import org.checkerframework.checker.index.qual.NonNegative;
27

28
/**
29
 * A specialized {@link AbstractDynamicBatchProcessor} for {@link OmegaMembershipOracle}s that implements {@link
30
 * ParallelOmegaOracle}.
31
 *
32
 * @param <I>
33
 *         input symbol type
34
 * @param <D>
35
 *         output domain type
36
 */
37
public class DynamicParallelOmegaOracle<S, I, D>
38
        extends AbstractDynamicBatchProcessor<OmegaQuery<I, D>, OmegaMembershipOracle<S, I, D>>
39
        implements ParallelOmegaOracle<S, I, D> {
40

41
    public DynamicParallelOmegaOracle(Supplier<? extends OmegaMembershipOracle<S, I, D>> oracleSupplier,
42
                                      @NonNegative int batchSize,
43
                                      ExecutorService executor) {
44
        super(oracleSupplier, batchSize, executor);
2✔
45
    }
2✔
46

47
    @Override
48
    public void processQueries(Collection<? extends OmegaQuery<I, D>> omegaQueries) {
49
        processBatch(omegaQueries);
2✔
50
    }
2✔
51

52
    @Override
53
    public MembershipOracle<I, D> getMembershipOracle() {
54
        return getProcessor().getMembershipOracle();
×
55
    }
56

57
    @Override
58
    public boolean isSameState(Word<I> w1, S s1, Word<I> w2, S s2) {
59
        return getProcessor().isSameState(w1, s1, w2, s2);
×
60
    }
61
}
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2025 Coveralls, Inc