[已解决]c++ 多线程文件存储问题

猪猪虾

（下面回复没有解决本质问题，大家别走）

我脑子已经转不动了，实在看不出来啥地方有问题了

有两个类，一个叫EventAction,另一个叫SteppingAction,一次EventAction的调用，会执行多次的SteppingAction的调用，总的会执行很多次的EventAction
我在EventAction类里面，每次EventAction类运行结束，我就对EventAction进行累加，并且加锁的方式判断当前是第几次EventAction，假设我有20次EventAction要执行，每5次的结果依次保存在一个新的txt文件夹里面，
当满足这个条件，我就EventAction里面重命名txt;

另一方面，在SteppingAction里面，我实时获取EventAction里面的txt的文件名字，然后将结果保存到新的txt里面

但是现在问题是，总是只有第一个默认的txt产生，其他txt在执行结束之后，都没有生成。我打印EventAction和SteppingAction里面的中间过程发现，txt名字的更改都是对的且传递也是对的，那么问题在哪呢

txt相关的主要在两个函数里面
EventAction.c 的 void EventAction::EndOfEventAction(const G4Event* aEvent)
以及 SteppingAction.c的void SteppingAction::UserSteppingAction(const G4Step* step)

1. //
   
2. //
   
3. /// \file EventAction.hh
   
4. namespace B1
   
5. {
   
6. 
   
7.     class RunAction;
   
8. 
   
9.     class EventAction : public G4UserEventAction
   
10.     {
    
11.     public:
    
12.         EventAction(RunAction* runAction);
    
13.         ~EventAction() override;
    
14. 
    
15.         void BeginOfEventAction(const G4Event* event) override;
    
16.         void EndOfEventAction(const G4Event* event) override;
    
17. 
    
18.         void AddEdep(G4int edep) { fEdep += edep; }
    
19. 
    
20.         void test();
    
21. 
    
22.         G4String Get_newFilename(){return filename_in_Event;};
    
23.     private:
    
24. 
    
25.         RunAction* fRunAction = nullptr;
    
26.         G4double   fEdep = 0.;  //相当于全局变量，能量作加和，在AddEdep实现不断累加
    
27. 
    
28.         static std::mutex myLock; // 用于保护需要同步的资源
    
29.         static G4int TotalCount ;
    
30.         static G4int FileCount ;
    
31. 
    
32.         G4String filename_in_Event;
    
33.     };
    
34. }
    
35. 
    

复制代码

1. //
   
2. /// \file EventAction.cc
   
3. /// \brief Implementation of the B1::EventAction class
   
4. 
   
5. namespace B1
   
6. {
   
7. 
   
8.     std::mutex EventAction::myLock;
   
9.     G4int EventAction::TotalCount = 0;
   
10.     G4int EventAction::FileCount = 0;
    
11. 
    
12.     EventAction::EventAction(RunAction* runAction)
    
13.             : fRunAction(runAction)
    
14.     {
    
15. 
    
16.     }
    
17. 
    
18. 
    
19.     EventAction::~EventAction()
    
20.     {}
    
21. 
    
22.     void EventAction::BeginOfEventAction(const G4Event*)
    
23.     {
    
24.         fEdep = 0.;
    
25.     }
    
26. 
    
27.     void EventAction::EndOfEventAction(const G4Event* aEvent)
    
28.     {
    
29.         std::lock_guard<std::mutex> lock(myLock);  // 加锁
    
30. 
    
31.         TotalCount ++;
    
32.         filename_in_Event = "NULL";
    
33.         if(TotalCount %10000000 ==0)
    
34.         {
    
35.             FileCount ++;
    
36.             filename_in_Event = "DataOfRun_" + std::to_string(FileCount) + ".txt";
    
37. //            G4cout<< "*!!!!!!!!!!!!!!!!!!******* EndOfEventAction ,TotalCount : "<< TotalCount <<
    
38. //                  ",filename_in_Event :"<<filename_in_Event<<G4endl;
    
39.         }
    
40. 
    
41.      //   test();
    
42.     }
    
43. 
    
44.     void EventAction::test()
    
45.     {
    
46.         G4String temp = "NULL";
    
47.         temp = Get_newFilename();
    
48.         if(temp == "NULL")
    
49.         {
    
50.             G4cout<< "*!!!!!!!!!!!!!!!!!!******* in EventAction :NULL "<<G4endl;
    
51.         }
    
52.         else
    
53.         {
    
54.             G4cout<< "*!!!!!!!!!!!!!!!!!!******* in EventAction : "<< temp<<G4endl;
    
55.         }
    
56. 
    
57.     }
    
58. 
    
59. }
    

复制代码

1. //
   
2. /// \file SteppingAction.hh
   
3. using namespace std;
   
4. namespace B1
   
5. {
   
6. 
   
7.     class EventAction;
   
8. 
   
9.     class SteppingAction : public G4UserSteppingAction
   
10.     {
    
11.     public:
    
12.         SteppingAction(EventAction* eventAction);
    
13.         ~SteppingAction() override;
    
14.         void UserSteppingAction(const G4Step*) override;
    
15.     private:
    
16.         EventAction* fEventAction = nullptr;
    
17.         G4LogicalVolume* fScoringVolume = nullptr;
    
18. 
    
19.         G4String filename;
    
20.     };
    
21. 
    
22. }
    

复制代码

1. //
   
2. /// \file SteppingAction.cc
   
3. /// \brief Implementation of the B1::SteppingAction class
   
4. namespace B1
   
5. {
   
6.     SteppingAction::SteppingAction(EventAction* eventAction)
   
7.             : fEventAction(eventAction)
   
8.     {
   
9.         filename = "DataOfRun_0.txt";
   
10.     }
    
11. 
    
12.     SteppingAction::~SteppingAction()
    
13.     {}
    
14. 
    
15.     void SteppingAction::UserSteppingAction(const G4Step* step) {
    
16.         G4String volumeName = step->GetPreStepPoint()->GetPhysicalVolume()->GetName();
    
17.         G4String ParticleName = step->GetTrack()->GetDynamicParticle()->GetParticleDefinition()->GetParticleName();
    
18. 
    
19.         G4String Newfilename = fEventAction->Get_newFilename();
    
20. //        G4cout<< "*!!!!!!!!!!!!!!!!!!******* Newfilename: "<< Newfilename <<G4endl;
    
21. //        G4cout<<"#############  gaga : volumeName " << volumeName <<G4endl;
    
22. //        if (ParticleName == "gamma" && volumeName == "DetectorArray")
    
23.         if (volumeName == "DetectorArray")
    
24.         {
    
25.             G4int copyNo = step->GetPreStepPoint()->GetTouchableHandle()->GetCopyNumber(0);  
    
26.             G4double edep = step->GetTotalEnergyDeposit();
    
27.          
    
28.             if(Newfilename  != "NULL")
    
29.             {
    
30.                 ofstream outf;
    
31.                 outf.open(Newfilename,ios::app);
    
32.                 outf<< copyNo << ' ' << edep << ' ';
    
33.                 outf.close();
    
34.             }
    
35.             else
    
36.             {
    
37. //                G4cout<< "*!!!!!!!!!!!!!!!!!!******* in stepAction :NULL , filename = " << filename <<G4endl;
    
38.                 ofstream outf;
    
39.                 outf.open(filename,ios::app);
    
40.                 outf<< copyNo << ' ' << edep << ' ';
    
41.                 outf.close();
    
42.             }
    
43.         }
    
44.     }
    
45. 
    
46. 
    
47. }

复制代码

最佳答案

月排行榜 / 总排行榜

isdkz

2023-8-27 17:25:55

问题的原因是在EventAction类中，每次EventAction类运行结束后，你使用锁来判断当前是第几次EventAction，并根据条件对文件进行重命名。然而，在SteppingAction类中，你实时获取EventAction类中的文件名，并将结果保存到新的文件中。但是，你在SteppingAction类中使用的文件名始终是初始化时的默认文件名，而不是EventAction类中实时更新的文件名。

解决这个问题的方法是，在SteppingAction类中，你应该使用EventAction类的成员函数Get_newFilename()来获取实时更新的文件名。你可以在SteppingAction类的构造函数中将EventAction类的指针作为参数传递，并将其存储在SteppingAction类的成员变量fEventAction中。然后，在UserSteppingAction函数中，使用fEventAction->Get_newFilename()来获取实时更新的文件名。

以下是修改后的代码示例：

1. // SteppingAction.hh
   
2. using namespace std;
   
3. 
   
4. namespace B1
   
5. {
   
6.     class EventAction;
   
7. 
   
8.     class SteppingAction : public G4UserSteppingAction
   
9.     {
   
10.     public:
    
11.         SteppingAction(EventAction* eventAction);
    
12.         ~SteppingAction() override;
    
13.         void UserSteppingAction(const G4Step*) override;
    
14.     private:
    
15.         EventAction* fEventAction = nullptr;
    
16.         G4LogicalVolume* fScoringVolume = nullptr;
    
17. 
    
18.         G4String filename;
    
19.     };
    
20. }
    
21. 
    
22. // SteppingAction.cc
    
23. namespace B1
    
24. {
    
25.     SteppingAction::SteppingAction(EventAction* eventAction)
    
26.         : fEventAction(eventAction)
    
27.     {
    
28.         filename = "DataOfRun_0.txt";
    
29.     }
    
30. 
    
31.     SteppingAction::~SteppingAction()
    
32.     {}
    
33. 
    
34.     void SteppingAction::UserSteppingAction(const G4Step* step)
    
35.     {
    
36.         G4String volumeName = step->GetPreStepPoint()->GetPhysicalVolume()->GetName();
    
37.         G4String ParticleName = step->GetTrack()->GetDynamicParticle()->GetParticleDefinition()->GetParticleName();
    
38. 
    
39.         G4String Newfilename = fEventAction->Get_newFilename();
    
40.         // 使用实时更新的文件名Newfilename
    
41.         if (volumeName == "DetectorArray")
    
42.         {
    
43.             G4int copyNo = step->GetPreStepPoint()->GetTouchableHandle()->GetCopyNumber(0);
    
44.             G4double edep = step->GetTotalEnergyDeposit();
    
45. 
    
46.             if (Newfilename != "NULL")
    
47.             {
    
48.                 ofstream outf;
    
49.                 outf.open(Newfilename, ios::app);
    
50.                 outf << copyNo << ' ' << edep << ' ';
    
51.                 outf.close();
    
52.             }
    
53.             else
    
54.             {
    
55.                 ofstream outf;
    
56.                 outf.open(filename, ios::app);
    
57.                 outf << copyNo << ' ' << edep << ' ';
    
58.                 outf.close();
    
59.             }
    
60.         }
    
61.     }
    
62. }
    

复制代码

通过这种方式，你将能够在SteppingAction类中使用实时更新的文件名，并将结果保存到正确的文件中。

跳转到最佳答案楼层

陶远航

根据你提供的代码，我看到你使用了互斥锁来保护资源的访问，但是在文件操作部分存在一些问题。

首先，在EventAction类中，你使用Get_newFilename()方法获取当前的文件名。然而，在BeginOfEventAction和EndOfEventAction函数中都调用了test()方法，这意味着每次事件开始和结束时都会调用Get_newFilename()方法，导致在同一个事件中可能多次获取相同的文件名。

其次，在SteppingAction类中，在写入文件之前，你也通过fEventAction->Get_newFilename()方法获取文件名，并将其赋值给Newfilename。但是，你并没有在调用ofstream对象的open函数之前检查Newfilename是否为"NULL"，这可能导致打开的文件名为空或错误。你应该在打开文件之前检查文件名是否为空。

另外，你在SteppingAction类的构造函数中将filename初始化为"DataOfRun_0.txt"，但是在代码中并没有修改filename的值。因此，在执行保存数据到文件的操作时，始终使用的是默认的文件名。

最后，你可以尝试给文件操作的代码添加一些debug信息，例如打印文件名和相关的提示信息，以便更好地排查问题所在。

希望以上解释和建议能够帮助你找到问题所在并解决它。
如果问题已经解决，请设置最佳答案

isdkz

问题的原因是在EventAction类中，每次EventAction类运行结束后，你使用锁来判断当前是第几次EventAction，并根据条件对文件进行重命名。然而，在SteppingAction类中，你实时获取EventAction类中的文件名，并将结果保存到新的文件中。但是，你在SteppingAction类中使用的文件名始终是初始化时的默认文件名，而不是EventAction类中实时更新的文件名。

解决这个问题的方法是，在SteppingAction类中，你应该使用EventAction类的成员函数Get_newFilename()来获取实时更新的文件名。你可以在SteppingAction类的构造函数中将EventAction类的指针作为参数传递，并将其存储在SteppingAction类的成员变量fEventAction中。然后，在UserSteppingAction函数中，使用fEventAction->Get_newFilename()来获取实时更新的文件名。

以下是修改后的代码示例：

1. // SteppingAction.hh
   
2. using namespace std;
   
3. 
   
4. namespace B1
   
5. {
   
6.     class EventAction;
   
7. 
   
8.     class SteppingAction : public G4UserSteppingAction
   
9.     {
   
10.     public:
    
11.         SteppingAction(EventAction* eventAction);
    
12.         ~SteppingAction() override;
    
13.         void UserSteppingAction(const G4Step*) override;
    
14.     private:
    
15.         EventAction* fEventAction = nullptr;
    
16.         G4LogicalVolume* fScoringVolume = nullptr;
    
17. 
    
18.         G4String filename;
    
19.     };
    
20. }
    
21. 
    
22. // SteppingAction.cc
    
23. namespace B1
    
24. {
    
25.     SteppingAction::SteppingAction(EventAction* eventAction)
    
26.         : fEventAction(eventAction)
    
27.     {
    
28.         filename = "DataOfRun_0.txt";
    
29.     }
    
30. 
    
31.     SteppingAction::~SteppingAction()
    
32.     {}
    
33. 
    
34.     void SteppingAction::UserSteppingAction(const G4Step* step)
    
35.     {
    
36.         G4String volumeName = step->GetPreStepPoint()->GetPhysicalVolume()->GetName();
    
37.         G4String ParticleName = step->GetTrack()->GetDynamicParticle()->GetParticleDefinition()->GetParticleName();
    
38. 
    
39.         G4String Newfilename = fEventAction->Get_newFilename();
    
40.         // 使用实时更新的文件名Newfilename
    
41.         if (volumeName == "DetectorArray")
    
42.         {
    
43.             G4int copyNo = step->GetPreStepPoint()->GetTouchableHandle()->GetCopyNumber(0);
    
44.             G4double edep = step->GetTotalEnergyDeposit();
    
45. 
    
46.             if (Newfilename != "NULL")
    
47.             {
    
48.                 ofstream outf;
    
49.                 outf.open(Newfilename, ios::app);
    
50.                 outf << copyNo << ' ' << edep << ' ';
    
51.                 outf.close();
    
52.             }
    
53.             else
    
54.             {
    
55.                 ofstream outf;
    
56.                 outf.open(filename, ios::app);
    
57.                 outf << copyNo << ' ' << edep << ' ';
    
58.                 outf.close();
    
59.             }
    
60.         }
    
61.     }
    
62. }
    

复制代码

通过这种方式，你将能够在SteppingAction类中使用实时更新的文件名，并将结果保存到正确的文件中。

猪猪虾

isdkz 发表于 2023-8-27 17:25
问题的原因是在EventAction类中，每次EventAction类运行结束后，你使用锁来判断当前是第几次EventAction， ...

虽然初始化是固定的文件名，但是在void SteppingAction::UserSteppingAction(const G4Step* step)函数里面，
我做了if判断的，先判断传进来的文件名是不是被更新了，如果被更新了，我就优先使用新的文件名，我的逻辑是没有问题的对吧

sfqxx

领鱼币，再回答