endison1986
commented
1 year ago In my actual project, I create monster entities in a System. In order to take advantage of multi-core, I use parallelStream and create monster entities in it, and cache the Entity to Component, but I found that in the next System, the Entity in the Component obtained by the context.findEntitiesWith() method is different from the hashCode of ResultSet.entity()
example code like this.
public enum State {
S1, S2, S3;
}
public static class C {
private final Entity entity;
public C(Entity entity) {
this.entity = entity;
}
}
public static class B {
}
public static class A {
private C c;
public A(Dominion dominion) {
c = new C(dominion.createEntity(this));
c.entity.setState(S1);
}
}
public static void main(String[] args) {
final Dominion dominion = Dominion.create();
final var list = List.<Runnable>of(() -> {
for (int i = 0; i < 200; i++) {
final var a = new A(dominion);
a.c.entity.add(new B());
}
}, () -> {
for (int i = 0; i < 200; i++) {
final var a = new A(dominion);
a.c.entity.add(new B());
}
}, () -> {
for (int i = 0; i < 200; i++) {
final var a = new A(dominion);
a.c.entity.add(new B());
}
});
final var scheduler = dominion.createScheduler();
scheduler.schedule(() -> list.parallelStream().forEach(Runnable::run));
scheduler.schedule(() -> {
dominion.findEntitiesWith(A.class).stream().forEach(rs->{
if(rs.entity().hashCode() != rs.comp().c.entity.hashCode()) {
System.out.println("1111111111111111111");
System.exit(-1);
}
});
System.exit(0);
});
scheduler.tickAtFixedRate(10);
}If I remove a.c.entity.add(new B());, the program is fine.
If I change paralleStream() to stream(), this program is fine.
enricostara
this code is fine.
this code is also fine.
but I get some error with this code
and this code