#2873 Delegate deletion of summary cases to separate thread.

This commit is contained in:
Gaute Lindkvist 2018-05-16 14:56:33 +02:00
parent ec9e2efef4
commit 0089e0c218
9 changed files with 170 additions and 8 deletions

View File

@ -30,6 +30,7 @@
#include "RiuPlotMainWindow.h"
#include "cafAsyncObjectDeleter.h"
#include "cafSelectionManager.h"
#include "cvfAssert.h"
@ -50,7 +51,7 @@ void RicCloseSummaryCaseFeature::setupActionLook(QAction* actionToSetup)
//--------------------------------------------------------------------------------------------------
///
//--------------------------------------------------------------------------------------------------
void RicCloseSummaryCaseFeature::deleteSummaryCases(const std::vector<RimSummaryCase*>& cases)
void RicCloseSummaryCaseFeature::deleteSummaryCases(std::vector<RimSummaryCase*>& cases)
{
RimSummaryPlotCollection* summaryPlotColl = RiaSummaryTools::summaryPlotCollection();
@ -66,13 +67,13 @@ void RicCloseSummaryCaseFeature::deleteSummaryCases(const std::vector<RimSummary
summaryCase->firstAncestorOrThisOfTypeAsserted(summaryCaseMainCollection);
summaryCaseMainCollection->removeCase(summaryCase);
delete summaryCase;
summaryCaseMainCollection->updateAllRequiredEditors();
}
RiuPlotMainWindow* mainPlotWindow = RiaApplication::instance()->mainPlotWindow();
mainPlotWindow->updateSummaryPlotToolBar();
caf::AsyncRawPointerVectorDeleter<RimSummaryCase> summaryCaseDeleter(std::move(cases));
}
//--------------------------------------------------------------------------------------------------

View File

@ -32,7 +32,7 @@ class RicCloseSummaryCaseFeature : public caf::CmdFeature
{
CAF_CMD_HEADER_INIT;
public:
static void deleteSummaryCases(const std::vector<RimSummaryCase*>& cases);
static void deleteSummaryCases(std::vector<RimSummaryCase*>& cases);
protected:
// Overrides

View File

@ -53,7 +53,7 @@ RimSummaryCaseCollection::RimSummaryCaseCollection()
//--------------------------------------------------------------------------------------------------
RimSummaryCaseCollection::~RimSummaryCaseCollection()
{
m_cases.deleteAllChildObjects();
m_cases.deleteAllChildObjectsAsync();
updateReferringCurveSets();
}

View File

@ -75,8 +75,8 @@ RimSummaryCaseMainCollection::RimSummaryCaseMainCollection()
//--------------------------------------------------------------------------------------------------
RimSummaryCaseMainCollection::~RimSummaryCaseMainCollection()
{
m_cases.deleteAllChildObjects();
m_caseCollections.deleteAllChildObjects();
m_cases.deleteAllChildObjectsAsync();
m_caseCollections.deleteAllChildObjectsAsync();
}
//--------------------------------------------------------------------------------------------------

View File

@ -45,6 +45,9 @@ set( PROJECT_FILES
cafTristate.h
cafFilePath.cpp
cafFilePath.h
cafAsyncObjectDeleter.h
cafAsyncObjectDeleter.inl
)
add_library( ${PROJECT_NAME}

View File

@ -0,0 +1,64 @@
//##################################################################################################
//
// Custom Visualization Core library
// Copyright (C) 2011-2013 Ceetron AS
//
// This library may be used under the terms of either the GNU General Public License or
// the GNU Lesser General Public License as follows:
//
// GNU General Public License Usage
// This library is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// This library is distributed in the hope that it will be useful, but WITHOUT ANY
// WARRANTY; without even the implied warranty of MERCHANTABILITY or
// FITNESS FOR A PARTICULAR PURPOSE.
//
// See the GNU General Public License at <<http://www.gnu.org/licenses/gpl.html>>
// for more details.
//
// GNU Lesser General Public License Usage
// This library is free software; you can redistribute it and/or modify
// it under the terms of the GNU Lesser General Public License as published by
// the Free Software Foundation; either version 2.1 of the License, or
// (at your option) any later version.
//
// This library is distributed in the hope that it will be useful, but WITHOUT ANY
// WARRANTY; without even the implied warranty of MERCHANTABILITY or
// FITNESS FOR A PARTICULAR PURPOSE.
//
// See the GNU Lesser General Public License at <<http://www.gnu.org/licenses/lgpl-2.1.html>>
// for more details.
//
//##################################################################################################
#pragma once
namespace caf
{
template<typename T>
class AsyncRawPointerVectorDeleter
{
public:
AsyncRawPointerVectorDeleter(std::vector<T*>&& pointerVector);
~AsyncRawPointerVectorDeleter();
void start();
private:
std::vector<T*> pointersToDelete_;
};
template<typename T>
class AsyncPdmPointerVectorDeleter
{
public:
AsyncPdmPointerVectorDeleter(std::vector<PdmPointer<T>>&& pdmPointerVector);
~AsyncPdmPointerVectorDeleter();
void start();
private:
std::vector<PdmPointer<T>> pointersToDelete_;
};
}
#include "cafAsyncObjectDeleter.inl"

View File

@ -0,0 +1,78 @@
#include <thread>
namespace caf
{
//--------------------------------------------------------------------------------------------------
/// Constructor that takes ownership of the data in the provided vector
//--------------------------------------------------------------------------------------------------
template<typename T>
AsyncRawPointerVectorDeleter<T>::AsyncRawPointerVectorDeleter(std::vector<T*>&& pointerVector)
: pointersToDelete_(std::move(pointerVector))
{
}
//--------------------------------------------------------------------------------------------------
/// Destructor will launch the asynchronous deletion if start() hasn't already been run.
//--------------------------------------------------------------------------------------------------
template<typename T>
AsyncRawPointerVectorDeleter<T>::~AsyncRawPointerVectorDeleter()
{
if (!pointersToDelete_.empty())
{
start();
}
}
//--------------------------------------------------------------------------------------------------
/// Perform deletion of the pointers in a separate thread.
//--------------------------------------------------------------------------------------------------
template<typename T>
void AsyncRawPointerVectorDeleter<T>::start()
{
std::thread([](std::vector<T*>&& pointerVector)
{
for (T* pointerToDelete : pointerVector)
{
delete pointerToDelete;
}
}, std::move(pointersToDelete_)).detach();
}
//--------------------------------------------------------------------------------------------------
/// Constructor that takes ownership of the data in the provided vector
//--------------------------------------------------------------------------------------------------
template<typename T>
AsyncPdmPointerVectorDeleter<T>::AsyncPdmPointerVectorDeleter(std::vector<PdmPointer<T>>&& pdmPointerVector)
: pointersToDelete_(std::move(pdmPointerVector))
{
}
//--------------------------------------------------------------------------------------------------
/// Destructor will launch the asynchronous deletion if start() hasn't already been run.
//--------------------------------------------------------------------------------------------------
template<typename T>
AsyncPdmPointerVectorDeleter<T>::~AsyncPdmPointerVectorDeleter()
{
if (!pointersToDelete_.empty())
{
start();
}
}
//--------------------------------------------------------------------------------------------------
/// Perform deletion of the pointers in a separate thread.
//--------------------------------------------------------------------------------------------------
template<typename T>
void caf::AsyncPdmPointerVectorDeleter<T>::start()
{
std::thread([](std::vector<PdmPointer<T>>&& pointerVector)
{
for (PdmPointer<T>& pointerToDelete : pointerVector)
{
delete pointerToDelete.rawPtr();
}
}, std::move(pointersToDelete_)).detach();
}
}

View File

@ -61,7 +61,8 @@ public:
virtual size_t size() const { return m_pointers.size(); }
virtual bool empty() const { return m_pointers.empty(); }
virtual void clear();
virtual void deleteAllChildObjects();
virtual void deleteAllChildObjects();
virtual void deleteAllChildObjectsAsync();
virtual void insertAt(int indexAfter, PdmObjectHandle* obj);
virtual PdmObjectHandle* at(size_t index);

View File

@ -1,3 +1,4 @@
#include "cafAsyncObjectDeleter.h"
#include "cafClassTypeName.h"
#include "cafPdmObjectHandle.h"
@ -138,6 +139,20 @@ void PdmChildArrayField<DataType*>::deleteAllChildObjects()
m_pointers.clear();
}
//--------------------------------------------------------------------------------------------------
/// Transfers ownership of the objects pointed to a separate thread.
/// Then clears the container and lets the thread delete the objects.
//--------------------------------------------------------------------------------------------------
template<typename DataType>
void PdmChildArrayField<DataType*>::deleteAllChildObjectsAsync()
{
CAF_ASSERT(isInitializedByInitFieldMacro());
AsyncPdmPointerVectorDeleter<DataType> pointerDeleter(std::move(m_pointers));
CAF_ASSERT(m_pointers.empty()); // Object storage for m_pointers should be empty immediately.
}
//--------------------------------------------------------------------------------------------------
/// Removes the pointer at index from the container. Does not delete the object pointed to.
/// Todo: This implementation can't be necessary in the new regime. Should be to just remove