Lines Matching defs:batch
41 Batch<FakeTask> batch;
43 EXPECT_EQ(0, batch.num_tasks());
44 EXPECT_TRUE(batch.empty());
45 EXPECT_EQ(0, batch.size());
46 EXPECT_FALSE(batch.IsClosed());
49 batch.AddTask(std::unique_ptr<FakeTask>(task0));
51 EXPECT_EQ(1, batch.num_tasks());
52 EXPECT_FALSE(batch.empty());
53 EXPECT_EQ(task0->size(), batch.size());
54 EXPECT_EQ(task0->size(), batch.task(0).size());
55 EXPECT_FALSE(batch.IsClosed());
58 batch.AddTask(std::unique_ptr<FakeTask>(task1));
60 EXPECT_EQ(2, batch.num_tasks());
61 EXPECT_FALSE(batch.empty());
62 EXPECT_EQ(task0->size() + task1->size(), batch.size());
63 EXPECT_EQ(task1->size(), batch.task(1).size());
64 EXPECT_EQ(task1->size(), batch.mutable_task(1)->size());
65 EXPECT_FALSE(batch.IsClosed());
67 batch.Close();
68 EXPECT_TRUE(batch.IsClosed());
70 EXPECT_EQ(2, batch.num_tasks());
71 EXPECT_FALSE(batch.empty());
72 EXPECT_EQ(task0->size() + task1->size(), batch.size());
73 EXPECT_EQ(task0->size(), batch.task(0).size());
74 EXPECT_EQ(task1->size(), batch.task(1).size());
76 EXPECT_EQ(7, batch.RemoveTask()->size());
77 EXPECT_EQ(3, batch.size());
78 EXPECT_EQ(3, batch.RemoveTask()->size());
79 EXPECT_EQ(0, batch.size());
80 EXPECT_TRUE(batch.empty());
84 Batch<FakeTask> batch;
85 batch.AddTask(std::unique_ptr<FakeTask>(new FakeTask(3)));
86 EXPECT_FALSE(batch.IsClosed());
89 Env::Default()->StartThread(ThreadOptions(), "test", [&batch]() {
91 batch.Close();
93 batch.WaitUntilClosed();
94 EXPECT_TRUE(batch.IsClosed());
98 Batch<FakeTask>* batch = new Batch<FakeTask>;
99 batch->AddTask(std::unique_ptr<FakeTask>(new FakeTask(3)));
100 EXPECT_FALSE(batch->IsClosed());
104 ThreadOptions(), "test", [&batch, &do_delete, &deleted]() {
106 delete batch;
112 batch->Close();
