Skip to content

Commit

Permalink
Change UniqueQueue to use a queue and a set.
Browse files Browse the repository at this point in the history
  • Loading branch information
gregorycu authored and Zeno- committed Jan 15, 2015
1 parent 227e480 commit bd0d786
Show file tree
Hide file tree
Showing 2 changed files with 58 additions and 53 deletions.
12 changes: 8 additions & 4 deletions src/map.cpp
Expand Up @@ -1663,7 +1663,8 @@ void Map::transformLiquids(std::map<v3s16, MapBlock*> & modified_blocks)
/*
Get a queued transforming liquid node
*/
v3s16 p0 = m_transforming_liquid.pop_front();
v3s16 p0 = m_transforming_liquid.front();
m_transforming_liquid.pop_front();

MapNode n0 = getNodeNoEx(p0);

Expand Down Expand Up @@ -1909,7 +1910,10 @@ void Map::transformLiquids(std::map<v3s16, MapBlock*> & modified_blocks)
}
//infostream<<"Map::transformLiquids(): loopcount="<<loopcount<<std::endl;
while (must_reflow.size() > 0)
m_transforming_liquid.push_back(must_reflow.pop_front());
{
m_transforming_liquid.push_back(must_reflow.front());
must_reflow.pop_front();
}
updateLighting(lighting_modified_blocks, modified_blocks);


Expand Down Expand Up @@ -2380,8 +2384,8 @@ void ServerMap::finishBlockMake(BlockMakeData *data,
*/
while(data->transforming_liquid.size() > 0)
{
v3s16 p = data->transforming_liquid.pop_front();
m_transforming_liquid.push_back(p);
m_transforming_liquid.push_back(data->transforming_liquid.front());
data->transforming_liquid.pop_front();
}

/*
Expand Down
99 changes: 50 additions & 49 deletions src/util/container.h
Expand Up @@ -28,52 +28,53 @@ with this program; if not, write to the Free Software Foundation, Inc.,
#include <list>
#include <vector>
#include <map>
#include <set>
#include <queue>

/*
Queue with unique values with fast checking of value existence
Queue with unique values with fast checking of value existence
*/

template<typename Value>
class UniqueQueue
{
public:

/*
Does nothing if value is already queued.
Return value:
true: value added
false: value already exists
Does nothing if value is already queued.
Return value:
true: value added
false: value already exists
*/
bool push_back(Value value)
bool push_back(const Value& value)
{
// Check if already exists
if(m_map.find(value) != m_map.end())
return false;
if (m_set.insert(value).second)
{
m_queue.push(value);
return true;
}
return false;
}

// Add
m_map[value] = 0;
m_list.push_back(value);

return true;
void pop_front()
{
m_set.erase(m_queue.front());
m_queue.pop();
}

Value pop_front()
const Value& front() const
{
typename std::list<Value>::iterator i = m_list.begin();
Value value = *i;
m_map.erase(value);
m_list.erase(i);
return value;
return m_queue.front();
}

u32 size()
u32 size() const
{
return m_map.size();
return m_queue.size();
}

private:
std::map<Value, u8> m_map;
std::list<Value> m_list;
std::set<Value> m_set;
std::queue<Value> m_queue;
};

#if 1
Expand All @@ -84,14 +85,14 @@ class MutexedMap
MutexedMap()
{
}

void set(const Key &name, const Value &value)
{
JMutexAutoLock lock(m_mutex);

m_values[name] = value;
}

bool get(const Key &name, Value *result)
{
JMutexAutoLock lock(m_mutex);
Expand All @@ -101,24 +102,24 @@ class MutexedMap

if(n == m_values.end())
return false;

if(result != NULL)
*result = n->second;

return true;
}

std::list<Value> getValues()
{
std::list<Value> result;
for(typename std::map<Key, Value>::iterator
i = m_values.begin();
i != m_values.end(); ++i){
i = m_values.begin();
i != m_values.end(); ++i){
result.push_back(i->second);
}
return result;
}

void clear ()
{
m_values.clear();
Expand All @@ -131,16 +132,16 @@ class MutexedMap
#endif

/*
Generates ids for comparable values.
Id=0 is reserved for "no value".
Generates ids for comparable values.
Id=0 is reserved for "no value".
Is fast at:
- Returning value by id (very fast)
- Returning id by value
- Generating a new id for a value
Is fast at:
- Returning value by id (very fast)
- Returning id by value
- Generating a new id for a value
Is not able to:
- Remove an id/value pair (is possible to implement but slow)
Is not able to:
- Remove an id/value pair (is possible to implement but slow)
*/
template<typename T>
class MutexedIdGenerator
Expand All @@ -149,7 +150,7 @@ class MutexedIdGenerator
MutexedIdGenerator()
{
}

// Returns true if found
bool getValue(u32 id, T &value)
{
Expand All @@ -161,7 +162,7 @@ class MutexedIdGenerator
value = m_id_to_value[id-1];
return true;
}

// If id exists for value, returns the id.
// Otherwise generates an id for the value.
u32 getId(const T &value)
Expand All @@ -185,7 +186,7 @@ class MutexedIdGenerator
};

/*
FIFO queue (well, actually a FILO also)
FIFO queue (well, actually a FILO also)
*/
template<typename T>
class Queue
Expand All @@ -200,7 +201,7 @@ class Queue
m_list.push_back(t);
++m_list_size;
}

void push_front(T t)
{
m_list.push_front(t);
Expand Down Expand Up @@ -246,7 +247,7 @@ class Queue
};

/*
Thread-safe FIFO queue (well, actually a FILO also)
Thread-safe FIFO queue (well, actually a FILO also)
*/

template<typename T>
Expand All @@ -272,8 +273,8 @@ class MutexedQueue
}

/* this version of pop_front returns a empty element of T on timeout.
* Make sure default constructor of T creates a recognizable "empty" element
*/
* Make sure default constructor of T creates a recognizable "empty" element
*/
T pop_frontNoEx(u32 wait_time_max_ms)
{
if (m_size.Wait(wait_time_max_ms))
Expand Down Expand Up @@ -339,8 +340,8 @@ class MutexedQueue
}

/* this version of pop_back returns a empty element of T on timeout.
* Make sure default constructor of T creates a recognizable "empty" element
*/
* Make sure default constructor of T creates a recognizable "empty" element
*/
T pop_backNoEx(u32 wait_time_max_ms=0)
{
if (m_size.Wait(wait_time_max_ms))
Expand Down

0 comments on commit bd0d786

Please sign in to comment.